Log TimeoutErrors. Fetch timeout 200ms

didx-xyz · Feb 19, 2025 · ea0a902 · ea0a902
1 parent 86ebf0a
commit ea0a902
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/waypoint/services/nats_service.py b/waypoint/services/nats_service.py
@@ -171,7 +171,7 @@ async def event_generator(*, subscription: JetStreamContext.PullSubscription):
 
                     try:
                         messages = await subscription.fetch(
-                            batch=5, timeout=0.5, heartbeat=0.2
+                            batch=5, timeout=0.5, heartbeat=0.01
                         )
                         for message in messages:
                             event = orjson.loads(message.data)
@@ -185,6 +185,7 @@ async def event_generator(*, subscription: JetStreamContext.PullSubscription):
                         await asyncio.sleep(0.1)
 
                     except TimeoutError:
+                        bound_logger.error("<><><>TimeoutError<><><>")
                         if nr_of_timeout_errors == 5:
                             bound_logger.warning(
                                 "Subscription lost connection, attempting to resubscribe..."