diff --git a/server/webhook-ingest/app/nats_client.py b/server/webhook-ingest/app/nats_client.py index 572b3743..dbb5b2ea 100644 --- a/server/webhook-ingest/app/nats_client.py +++ b/server/webhook-ingest/app/nats_client.py @@ -12,6 +12,7 @@ def __init__(self, nats_url: str, nats_auth_token: str): async def connect(self): protocol, host = self.nats_url.split("://") server_url = f"{protocol}://{self.nats_auth_token}@{host}" + logger.info(f"Connecting to NATS at {server_url}") await self.nc.connect(server_url) self.js = self.nc.jetstream() logger.info(f"Connected to NATS at {self.nats_url}")