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

Handle the situation where we could not communiate with celery

Browse Source
This commit is contained in:
Matthew Jones
2014-03-12 16:11:56 -04:00
parent 93e68009a7
commit 3c82085b93
1 changed files with 8 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
awx/main/management/commands/run_task_system.py
View File

@@ -145,13 +145,17 @@ def rebuild_graph(message):
inspector = inspect() inspector = inspect()
active_task_queues = inspector.active() active_task_queues = inspector.active()
active_tasks = [] active_tasks = []
for queue in active_task_queues: if active_task_queues is not None:
active_tasks += [at['id'] for at in active_task_queues[queue]] for queue in active_task_queues:
active_tasks += [at['id'] for at in active_task_queues[queue]]
else:
if settings.DEBUG:
print("Could not communicate with celery!")
# TODO: Something needs to be done here to signal to the system as a whole that celery appears to be down
return None
all_sorted_tasks = get_tasks() all_sorted_tasks = get_tasks()
if not len(all_sorted_tasks): if not len(all_sorted_tasks):
return None return None
running_tasks = filter(lambda t: t.status == 'running', all_sorted_tasks) running_tasks = filter(lambda t: t.status == 'running', all_sorted_tasks)
waiting_tasks = filter(lambda t: t.status != 'running', all_sorted_tasks) waiting_tasks = filter(lambda t: t.status != 'running', all_sorted_tasks)
new_tasks = filter(lambda t: t.status == 'new', all_sorted_tasks) new_tasks = filter(lambda t: t.status == 'new', all_sorted_tasks)