shutdown eventloop

Signed-off-by: Sreekanth <prsreekanth920@gmail.com>

Author: BulkBeing

packages/pynumaflow/poetry.lock

@@ -173,9 +173,14 @@ async def _watch_for_shutdown():
         shutdown_task = asyncio.create_task(_watch_for_shutdown())
         await server.wait_for_termination()
 
+
         # Propagate error so start() can exit with a non-zero code
         self._error = self.servicer._error
 
         shutdown_task.cancel()
         with contextlib.suppress(asyncio.CancelledError):
             await shutdown_task
+
+        _LOGGER.info("Stopping event loop...")
+        asyncio.get_event_loop().stop()
+        _LOGGER.info("Event loop stopped")

packages/pynumaflow/pynumaflow/sinker/async_server.py

@@ -28,7 +28,7 @@ grpcio-tools = "^1.48.1"
 google-api-core = "^2.11.0"
 grpcio-status = "^1.48.1"
 protobuf = ">=6.31.1,<7.0"
-aiorun = "^2023.7"
+aiorun = "^2025.1.1"
 uvloop = ">=0.21.0"
 psutil = "^6.0.0"