diff --git a/waypoint/services/nats_service.py b/waypoint/services/nats_service.py index b7623ef17..791926651 100644 --- a/waypoint/services/nats_service.py +++ b/waypoint/services/nats_service.py @@ -137,7 +137,9 @@ async def event_generator(): break try: - messages = await subscription.fetch(batch=5, timeout=0.2, heartbeat=0.01) + messages = await subscription.fetch( + batch=5, timeout=0.2, heartbeat=0.02 + ) for message in messages: event = orjson.loads(message.data) logger.trace("Received event: {}", event)