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)