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.
1 parent ff36584 commit 30ff193Copy full SHA for 30ff193
tests/test_celery_ping.py
@@ -160,10 +160,18 @@ def test_check_status_reports_destinations(
160
{"celery2@4cc150a7b49b": CeleryPingHealthCheck.CORRECT_PING_RESPONSE},
161
{"celery3@4cc150a7b49b": CeleryPingHealthCheck.CORRECT_PING_RESPONSE},
162
],
163
+ ), patch(
164
+ self.CELERY_APP_CONTROL_INSPECT_ACTIVE_QUEUES,
165
+ return_value={
166
+ celery_worker: [
167
+ {"name": queue.name} for queue in settings.CELERY_QUEUES
168
+ ]
169
+ for celery_worker in ("celery1@4cc150a7b49b", "celery2@4cc150a7b49b", "celery3@4cc150a7b49b")
170
+ },
171
):
172
health_check.check_status()
173
- assert len(health_check.errors) == 1
174
+ assert not health_check.errors
175
176
177
class TestCeleryPingHealthCheckApps:
0 commit comments