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)