From 045c50718b8952a1480550cf8076d1e240456302 Mon Sep 17 00:00:00 2001 From: Thomas Steinacher Date: Wed, 24 Apr 2024 12:06:39 +0100 Subject: [PATCH] Task lock should be non-local --- tasktiger/worker.py | 1 + 1 file changed, 1 insertion(+) diff --git a/tasktiger/worker.py b/tasktiger/worker.py index 6c1c49c..ca9609f 100644 --- a/tasktiger/worker.py +++ b/tasktiger/worker.py @@ -674,6 +674,7 @@ def _execute_task_group( lock = self.connection.lock( self._key("lockv2", lock_id), timeout=self.config["ACTIVE_TASK_UPDATE_TIMEOUT"], + thread_local=False, ) if not lock.acquire(blocking=False): log.info("could not acquire lock", task_id=task.id)