diff --git a/awx/main/scheduler/task_manager.py b/awx/main/scheduler/task_manager.py index d4b9daf80b..3607e53241 100644 --- a/awx/main/scheduler/task_manager.py +++ b/awx/main/scheduler/task_manager.py @@ -679,9 +679,9 @@ class TaskManager(): return finished_wfjs def schedule(self): - with transaction.atomic(): - # Lock - with advisory_lock('task_manager_lock', wait=False) as acquired: + # Lock + with advisory_lock('task_manager_lock', wait=False) as acquired: + with transaction.atomic(): if acquired is False: logger.debug("Not running scheduler, another task holds lock") return