Ignore checking celery task list during some unit tests, triggered by UNIT_TEST_IGNORE_TASK_WAIT

This commit is contained in:
Matthew Jones
2014-03-17 14:53:38 -04:00
parent 57fff65577
commit fe625785c7

View File

@@ -143,7 +143,12 @@ def rebuild_graph(message):
''' Regenerate the task graph by refreshing known tasks from Tower, purging orphaned running tasks, ''' Regenerate the task graph by refreshing known tasks from Tower, purging orphaned running tasks,
and creatingdependencies for new tasks before generating directed edge relationships between those tasks ''' and creatingdependencies for new tasks before generating directed edge relationships between those tasks '''
inspector = inspect() inspector = inspect()
active_task_queues = inspector.active() if not hasattr(settings, 'UNIT_TEST_IGNORE_TASK_WAIT'):
active_task_queues = inspector.active()
else:
print("Ignoring celery task inspector")
active_task_queues = None
active_tasks = [] active_tasks = []
if active_task_queues is not None: if active_task_queues is not None:
for queue in active_task_queues: for queue in active_task_queues: