put atomic block inside lock block

2026-02-28 08:18:43 -03:30 · 2018-08-30 12:54:53 -04:00
parent c5aa9ee12b
commit 786e907e3b
1 changed files with 3 additions and 3 deletions
--- 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