EventBroadcaster: Improve log messages

permitio · Jun 20, 2023 · 53f2a21 · 53f2a21
1 parent a2e77b5
commit 53f2a21
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/fastapi_websocket_pubsub/event_broadcaster.py b/fastapi_websocket_pubsub/event_broadcaster.py
@@ -262,7 +262,7 @@ async def __read_notifications__(self):
                 async for event in subscriber:
                     try:
                         notification = BroadcastNotification.parse_raw(event.message)
-                        logger.info(
+                        logger.debug(
                             "Handling incoming broadcast event: {}".format(
                                 {
                                     "topics": notification.topics,
@@ -276,3 +276,6 @@ async def __read_notifications__(self):
                         )
                     except:
                         logger.exception("Failed handling incoming broadcast")
+                logger.info(
+                    "No more events to read from subscriber (underlying connection closed)"
+                )