Commit 24cf80ad by Őry Máté

vm: fix flake8

parent db39311c
...@@ -13,7 +13,7 @@ def check_queue(node_hostname, queue_id): ...@@ -13,7 +13,7 @@ def check_queue(node_hostname, queue_id):
:param node_hostname: Short hostname of the node. :param node_hostname: Short hostname of the node.
:param queue_id: Queue identifier (eg. vm). :param queue_id: Queue identifier (eg. vm).
""" """
drivers = ['vmdriver', 'netdriver', 'agentdriver'] # 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
active_queues = get_queues() active_queues = get_queues()
...@@ -27,6 +27,7 @@ def check_queue(node_hostname, queue_id): ...@@ -27,6 +27,7 @@ def check_queue(node_hostname, queue_id):
return True return True
return False return False
def get_queues(): def get_queues():
"""Get active celery queues. """Get active celery queues.
...@@ -43,8 +44,6 @@ def get_queues(): ...@@ -43,8 +44,6 @@ def get_queues():
return result return result
@celery.task(name='vmdriver.create') @celery.task(name='vmdriver.create')
def deploy(params): def deploy(params):
pass pass
......
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