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

More docs and fix a bug where we could crash attempting to mark a job as

Browse Source 
failed when it wasn't running in celery
This commit is contained in:
Matthew Jones
2014-03-12 14:26:15 -04:00
parent 06cc5ffb4a
commit 2224382caa
1 changed files with 10 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -161,11 +161,11 @@ def rebuild_graph(message):
print("Active celery tasks: " + str(active_tasks)) print("Active celery tasks: " + str(active_tasks))
for task in list(running_tasks): for task in list(running_tasks):
if task.celery_task_id not in active_tasks: if task.celery_task_id not in active_tasks:
# Pull status again and make sure it didn't finish in the meantime # NOTE: Pull status again and make sure it didn't finish in the meantime?
task.status = 'failed' task.status = 'failed'
task.result_traceback += "Task was marked as running in Tower but was not present in Celery so it has been marked as failed" task.result_traceback += "Task was marked as running in Tower but was not present in Celery so it has been marked as failed"
task.save() task.save()
running_tasks.pop(task) running_tasks.pop(running_tasks.index(task))
if settings.DEBUG: if settings.DEBUG:
print("Task %s appears orphaned... marking as failed" % task) print("Task %s appears orphaned... marking as failed" % task)
@@ -268,8 +268,15 @@ def run_taskmanager(command_port):
time.sleep(0.1) time.sleep(0.1)
class Command(NoArgsCommand): class Command(NoArgsCommand):
'''
Tower Task Management System
This daemon is designed to reside between our tasks and celery and provide a mechanism
for understanding the relationship between those tasks and their dependencies. It also
actively prevents situations in which Tower can get blocked because it doesn't have an
understanding of what is progressing through celery.
'''
help = 'Launch the job graph runner' help = 'Launch the Tower task management system'
def init_logging(self): def init_logging(self):
log_levels = dict(enumerate([logging.ERROR, logging.INFO, log_levels = dict(enumerate([logging.ERROR, logging.INFO,