diff --git a/jass/tasks.py b/jass/tasks.py index 2dbfd2751bce37aa5e0223b010d8a8a79bb54532..90e8f769d680ec5d1715e324500dde227bb63bf3 100644 --- a/jass/tasks.py +++ b/jass/tasks.py @@ -93,7 +93,11 @@ def get_queue_status(): for worker, queue in getattr(inspect, k)().items(): ret[k] += len(queue) workers.add(worker) - except ValueError: + except ( + AttributeError, # when no worker + ConnectionResetError, # when rabbitMQ went down + TimeoutError, # when rabbitMQ is not reachable + ): pass ret['worker'] = len(workers) return ret