From 79f3ad5f230ac89e31a70771962395e731ed2193 Mon Sep 17 00:00:00 2001 From: cl0ete Date: Tue, 10 Dec 2024 11:24:25 +0200 Subject: [PATCH] simplify exception handling --- waypoint/services/nats_service.py | 3 --- 1 file changed, 3 deletions(-) diff --git a/waypoint/services/nats_service.py b/waypoint/services/nats_service.py index 530d5ea28..8b63439c6 100644 --- a/waypoint/services/nats_service.py +++ b/waypoint/services/nats_service.py @@ -209,9 +209,6 @@ async def event_generator( state=state, start_time=start_time, ) - except asyncio.CancelledError: - logger.debug("Event generator cancelled") - stop_event.set() except Exception as e: # pylint: disable=W0718 logger.exception("Error processing events: {}", e)