Use get_running_loop instead of get_event_loop

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

Author: BulkBeing

packages/pynumaflow/pynumaflow/accumulator/async_server.py

@@ -239,5 +239,5 @@ async def _watch_for_shutdown():
         # event loop explicitly here, the python process will not exit.
         # It reamins stuck for 5 minutes until liveness and readiness probe
         # fails enough times and k8s sends a SIGTERM
-        asyncio.get_event_loop().stop()
+        asyncio.get_running_loop().stop()
         _LOGGER.info("Event loop stopped")

packages/pynumaflow/pynumaflow/batchmapper/async_server.py

@@ -174,5 +174,5 @@ async def _watch_for_shutdown():
         # event loop explicitly here, the python process will not exit.
         # It reamins stuck for 5 minutes until liveness and readiness probe
         # fails enough times and k8s sends a SIGTERM
-        asyncio.get_event_loop().stop()
+        asyncio.get_running_loop().stop()
         _LOGGER.info("Event loop stopped")

packages/pynumaflow/pynumaflow/mapper/async_server.py

@@ -172,5 +172,5 @@ async def _watch_for_shutdown():
         # event loop explicitly here, the python process will not exit.
         # It reamins stuck for 5 minutes until liveness and readiness probe
         # fails enough times and k8s sends a SIGTERM
-        asyncio.get_event_loop().stop()
+        asyncio.get_running_loop().stop()
         _LOGGER.info("Event loop stopped")

packages/pynumaflow/pynumaflow/mapstreamer/async_server.py

@@ -193,5 +193,5 @@ async def _watch_for_shutdown():
         # event loop explicitly here, the python process will not exit.
         # It reamins stuck for 5 minutes until liveness and readiness probe
         # fails enough times and k8s sends a SIGTERM
-        asyncio.get_event_loop().stop()
+        asyncio.get_running_loop().stop()
         _LOGGER.info("Event loop stopped")

packages/pynumaflow/pynumaflow/reducer/async_server.py

@@ -225,5 +225,5 @@ async def _watch_for_shutdown():
         # event loop explicitly here, the python process will not exit.
         # It reamins stuck for 5 minutes until liveness and readiness probe
         # fails enough times and k8s sends a SIGTERM
-        asyncio.get_event_loop().stop()
+        asyncio.get_running_loop().stop()
         _LOGGER.info("Event loop stopped")

packages/pynumaflow/pynumaflow/reducestreamer/async_server.py

@@ -237,5 +237,5 @@ async def _watch_for_shutdown():
             await shutdown_task
 
         _LOGGER.info("Stopping event loop...")
-        asyncio.get_event_loop().stop()
+        asyncio.get_running_loop().stop()
         _LOGGER.info("Event loop stopped")

packages/pynumaflow/pynumaflow/sinker/async_server.py

@@ -196,5 +196,5 @@ async def _watch_for_shutdown():
         # event loop explicitly here, the python process will not exit.
         # It reamins stuck for 5 minutes until liveness and readiness probe
         # fails enough times and k8s sends a SIGTERM
-        asyncio.get_event_loop().stop()
+        asyncio.get_running_loop().stop()
         _LOGGER.info("Event loop stopped")

packages/pynumaflow/pynumaflow/sourcer/async_server.py

@@ -233,5 +233,5 @@ async def _watch_for_shutdown():
         # event loop explicitly here, the python process will not exit.
         # It reamins stuck for 5 minutes until liveness and readiness probe
         # fails enough times and k8s sends a SIGTERM
-        asyncio.get_event_loop().stop()
+        asyncio.get_running_loop().stop()
         _LOGGER.info("Event loop stopped")

packages/pynumaflow/pynumaflow/sourcetransformer/async_server.py

@@ -195,5 +195,5 @@ async def _watch_for_shutdown():
         # event loop explicitly here, the python process will not exit.
         # It reamins stuck for 5 minutes until liveness and readiness probe
         # fails enough times and k8s sends a SIGTERM
-        asyncio.get_event_loop().stop()
+        asyncio.get_running_loop().stop()
         _LOGGER.info("Event loop stopped")