diff --git a/api/extensions/ext_celery.py b/api/extensions/ext_celery.py
index fcb99a9e83b501..bd4755e76889ec 100644
--- a/api/extensions/ext_celery.py
+++ b/api/extensions/ext_celery.py
@@ -28,6 +28,7 @@ def __call__(self, *args: object, **kwargs: object) -> object:
 
     celery_app.conf.update(
         result_backend=app.config["CELERY_RESULT_BACKEND"],
+        broker_connection_retry_on_startup=True,
     )
 
     if app.config["BROKER_USE_SSL"]: