diff --git a/transformer_sidecar/src/transformer_sidecar/transformer.py b/transformer_sidecar/src/transformer_sidecar/transformer.py
index 55a99a59..1350fff2 100644
--- a/transformer_sidecar/src/transformer_sidecar/transformer.py
+++ b/transformer_sidecar/src/transformer_sidecar/transformer.py
@@ -509,6 +509,7 @@ def prepend_xcache(file_paths: list[str]) -> list[str]:
     app.conf.worker_hijack_root_logger = False
     app.conf.worker_redirect_stdouts_level = 'DEBUG'
     app.conf.worker_prefetch_multiplier = 1
+    app.conf.broker_connection_retry_on_startup = True
     init(_args, app)
 
     logger.debug(