diff --git a/packages/opal-server/opal_server/pubsub.py b/packages/opal-server/opal_server/pubsub.py index c7a3b875e..d47e30d61 100644 --- a/packages/opal-server/opal_server/pubsub.py +++ b/packages/opal-server/opal_server/pubsub.py @@ -142,11 +142,19 @@ def __init__(self, signer: JWTSigner, broadcaster_uri: str = None): self.broadcaster = None if broadcaster_uri is not None: logger.info(f"Initializing broadcaster for server<->server communication") - self.broadcaster = EventBroadcaster( - broadcaster_uri, - notifier=self.notifier, - channel=opal_server_config.BROADCAST_CHANNEL_NAME, - ) + try: + self.broadcaster = EventBroadcaster( + broadcaster_uri, + notifier=self.notifier, + channel=opal_server_config.BROADCAST_CHANNEL_NAME, + ) + except Exception as e: + logger.error( + "Failed to initialize EventBroadcaster with uri: {broadcaster_uri}. Exception: {e}", + broadcaster_uri=broadcaster_uri, + e=e, + ) + self.broadcaster = None else: logger.info("Pub/Sub broadcaster is off")