Fixed active task checking logic

This commit is contained in:
Roberto Rosario
2011-04-24 04:41:53 -04:00
parent 06900f7cd9
commit c505dad667

View File

@@ -39,11 +39,11 @@ def task_process_queue_document(queue_document_id):
def reset_orphans():
i = inspect()
i = inspect().active()
active_tasks = []
if i:
for host, instances in i.active().items():
for host, instances in i.items():
for instance in instances:
active_tasks.append(instance['id'])