Commit f8bb2ede by Őry Máté

vm: cache list of queues

parent 1db410a2
from django.core.cache import cache
from logging import getLogger
from manager.mancelery import celery
logger = getLogger(__name__)
def check_queue(node_hostname, queue_id):
"""True if the queue is alive.
Example: check_queue('node01', 'vm'):
:param node_hostname: Short hostname of the node.
:param queue_id: Queue identifier (eg. vm).
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
inspect = celery.control.inspect(worker_list)
active_queues = inspect.active_queues()
active_queues = get_queues()
if active_queues is None:
return False
# v is List of List of queues dict
......@@ -17,6 +27,23 @@ def check_queue(node_hostname, queue_id):
return True
return False
def get_queues():
"""Get active celery queues.
Result is cached for 10 seconds!
key = __name__ + u'queues'
result = cache.get(key)
if result is None:
inspect = celery.control.inspect()
inspect.timeout = 0.1
result = inspect.active_queues()
logger.debug('Queue list of length %d cached.', len(result))
cache.set(key, result, 10)
return result
def deploy(params):
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