From 18311297b097c7512c53b3f4b1cb1e04fa47b3cf Mon Sep 17 00:00:00 2001 From: cl0ete Date: Wed, 4 Dec 2024 16:14:37 +0200 Subject: [PATCH] :art: & update heartbeat value --- waypoint/services/nats_service.py | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) 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)