Skip to content

CIRCLE / cloud

Go to a project
Commit 868ef1da by Bach Dániel
Options

vm: add agentdriver to check_queue()

parent a725be3a
Showing with 1 additions and 1 deletions
circle/vm/tasks/vm_tasks.py
...@@ -2,7 +2,7 @@ from manager.mancelery import celery ...@@ -2,7 +2,7 @@ from manager.mancelery import celery
def check_queue(node_hostname, queue_id): def check_queue(node_hostname, queue_id):
drivers = ['vmdriver', 'netdriver'] drivers = ['vmdriver', 'netdriver', 'agentdriver']
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)
......
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