From 66c1cfd44c7b54fe3c50be9fcb74fb96221f534e Mon Sep 17 00:00:00 2001 From: Guba Sándor Date: Wed, 19 Feb 2014 10:09:43 +0100 Subject: [PATCH] vm_task: return False when no workers found fixes #79 --- circle/vm/tasks/vm_tasks.py | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/circle/vm/tasks/vm_tasks.py b/circle/vm/tasks/vm_tasks.py index 16a2ac7..24bce9b 100644 --- a/circle/vm/tasks/vm_tasks.py +++ b/circle/vm/tasks/vm_tasks.py @@ -6,8 +6,11 @@ def check_queue(node_hostname, queue_id): worker_list = [node_hostname + "." + d for d in drivers] queue_name = node_hostname + "." + queue_id inspect = celery.control.inspect(worker_list) + active_queues = inspect.active_queues() + if active_queues is None: + return False # v is List of List of queues dict - node_workers = [v for k, v in inspect.active_queues().iteritems()] + node_workers = [v for k, v in active_queues.iteritems()] for worker in node_workers: for queue in worker: if queue['name'] == queue_name: -- libgit2 0.26.0