Skip to content

Commit

Permalink
Task lock should be non-local
Browse files Browse the repository at this point in the history
  • Loading branch information
thomasst committed Apr 24, 2024
1 parent 937d557 commit 045c507
Showing 1 changed file with 1 addition and 0 deletions.
1 change: 1 addition & 0 deletions tasktiger/worker.py
Original file line number Diff line number Diff line change
Expand Up @@ -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)
Expand Down

0 comments on commit 045c507

Please sign in to comment.