External-Mirrors/awx
2
0
Fork 0
mirror of https://github.com/ansible/awx.git synced 2026-05-19 14:57:39 -02:30
Code Issues Packages Projects Releases Wiki Activity

rectify celery<->db inconsistent running job

Browse Source
This commit is contained in:
Chris Meyers
2016-10-27 16:31:47 -04:00
parent 4ef4b4709b
commit 454b3edb7c
2 changed files with 30 additions and 31 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
awx/main/scheduler/tasks.py
View File

@@ -33,19 +33,19 @@ def run_scheduler():
@task
def run_fail_inconsistent_running_jobs():
return
print("run_fail_inconsistent_running_jobs() running")
with transaction.atomic():
# Lock
try:
Instance.objects.select_for_update(nowait=True).all()[0]
scheduler = Scheduler()
active_tasks = scheduler.get_activate_tasks()
active_tasks = scheduler.get_active_tasks()
if active_tasks is None:
# TODO: Failed to contact celery. We should surface this.
return None
all_sorted_tasks = scheduler.get_tasks()
scheduler.process_celery_tasks(active_tasks, all_sorted_tasks)
all_running_sorted_tasks = scheduler.get_running_tasks()
scheduler.process_celery_tasks(active_tasks, all_running_sorted_tasks)
except DatabaseError:
return