Skip to content

Commit 2dce8f7

Browse files
sl0thentr0pyclaude
andcommitted
test(celery): diag — fail fast on broker connect
So the py3.7-container kombu hang reveals its real exception instead of sleeping forever inside retry_over_time. Co-Authored-By: Claude Opus 4.7 (1M context) <noreply@anthropic.com>
1 parent 4ca1391 commit 2dce8f7

1 file changed

Lines changed: 6 additions & 0 deletions

File tree

tests/integrations/celery/integration_tests/test_celery_beat_cron_monitoring.py

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -23,6 +23,12 @@ def celery_config():
2323
"task_always_eager": False,
2424
"task_create_missing_queues": True,
2525
"task_default_queue": f"queue_{os.getpid()}",
26+
# DIAG (py3.7 container hang): fail fast on broker connect so the
27+
# actual exception surfaces instead of looping forever in
28+
# kombu.retry_over_time.
29+
"broker_connection_retry": False,
30+
"broker_connection_max_retries": 1,
31+
"broker_connection_timeout": 2,
2632
}
2733

2834

0 commit comments

Comments
 (0)