External-Mirrors/awx
2
0
Fork 0
mirror of https://github.com/ansible/awx.git synced 2026-02-26 07:26:03 -03:30
Code Issues Packages Projects Releases Wiki Activity

cheesy global lock

Browse Source
This commit is contained in:
Chris Meyers
2016-09-22 17:54:27 -04:00
parent 04f69727f2
commit 3a8033dec4
1 changed files with 11 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

22
awx/main/scheduler/__init__.py
View File

@@ -241,18 +241,18 @@ def process_graph(graph, task_capacity):
(str(node_obj), str(impact), str(remaining_volume))) (str(node_obj), str(impact), str(remaining_volume)))
def schedule(): def schedule():
lockfile = open("/tmp/tower_scheduler.lock", "w") with transaction.atomic():
fcntl.lockf(lockfile, fcntl.LOCK_EX) # Lock
Instance.objects.select_for_update().all()[0]
task_capacity = get_system_task_capacity() task_capacity = get_system_task_capacity()
workflow_jobs = get_running_workflow_jobs() workflow_jobs = get_running_workflow_jobs()
process_finished_workflow_jobs(workflow_jobs) process_finished_workflow_jobs(workflow_jobs)
spawn_workflow_graph_jobs(workflow_jobs) spawn_workflow_graph_jobs(workflow_jobs)
graph = rebuild_graph() graph = rebuild_graph()
if graph: if graph:
process_graph(graph, task_capacity) process_graph(graph, task_capacity)
fcntl.lockf(lockfile, fcntl.LOCK_UN)
# Unlock, due to transaction ending