Commit f5b9fa3f authored by Johan Bloemberg's avatar Johan Bloemberg
parent 8a8a9c54
Pipeline #17311745 passed with stages
in 6 minutes and 41 seconds
......@@ -96,10 +96,10 @@ def status():
active_queues = inspect.active_queues()
workers = [{
'name': worker_name,
'queues': [q['name'] for q in active_queues[worker_name]],
'queues': [q['name'] for q in active_queues.get(worker_name, [])],
'tasks_processed': sum(worker_stats['total'].values()),
'tasks_active': len(active[worker_name]),
'tasks_reserved': len(reserved[worker_name]),
'tasks_active': len(active.get(worker_name, [])),
'tasks_reserved': len(reserved.get(worker_name, [])),
'prefetch_count': worker_stats['prefetch_count'],
'concurrency': worker_stats['pool']['max-concurrency'],
} for worker_name, worker_stats in stats.items()]
......
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 to comment