We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
2 parents bc2d4ee + 1fc54c4 commit 50424c1Copy full SHA for 50424c1
health_check/contrib/celery_ping/backends.py
@@ -50,7 +50,12 @@ def _check_ping_result(self, ping_result):
50
self._check_active_queues(active_workers)
51
52
def _check_active_queues(self, active_workers):
53
- defined_queues = app.conf.CELERY_QUEUES
+ try:
54
+ # Celery 4+
55
+ defined_queues = app.conf.task_queues
56
+ except AttributeError:
57
+ # Celery <4
58
+ defined_queues = app.conf.CELERY_QUEUES
59
60
if not defined_queues:
61
return
0 commit comments