Commit 66c1cfd4 by Guba Sándor

vm_task: return False when no workers found fixes #79

parent cd43c8bd
...@@ -6,8 +6,11 @@ def check_queue(node_hostname, queue_id): ...@@ -6,8 +6,11 @@ def check_queue(node_hostname, queue_id):
worker_list = [node_hostname + "." + d for d in drivers] worker_list = [node_hostname + "." + d for d in drivers]
queue_name = node_hostname + "." + queue_id queue_name = node_hostname + "." + queue_id
inspect = celery.control.inspect(worker_list) 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 # 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 worker in node_workers:
for queue in worker: for queue in worker:
if queue['name'] == queue_name: if queue['name'] == queue_name:
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or sign in to comment