Skip to content
Snippets Groups Projects
Commit 6b34a01b authored by Bryan BRANCOTTE's avatar Bryan BRANCOTTE
Browse files

catch more scenarios

parent 2af4258f
No related branches found
No related tags found
1 merge request!67Draft: HPA for celery
...@@ -93,7 +93,11 @@ def get_queue_status(): ...@@ -93,7 +93,11 @@ def get_queue_status():
for worker, queue in getattr(inspect, k)().items(): for worker, queue in getattr(inspect, k)().items():
ret[k] += len(queue) ret[k] += len(queue)
workers.add(worker) workers.add(worker)
except ValueError: except (
AttributeError, # when no worker
ConnectionResetError, # when rabbitMQ went down
TimeoutError, # when rabbitMQ is not reachable
):
pass pass
ret['worker'] = len(workers) ret['worker'] = len(workers)
return ret return ret
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment