Fixing _get_running_loop

Author: vrdmr

azure_functions_worker/dispatcher.py

@@ -553,7 +553,7 @@ def set_azure_invocation_id(self, invocation_id: str) -> None:
 
 
 def get_current_invocation_id() -> Optional[str]:
-    loop = asyncio.events.get_running_loop()
+    loop = asyncio._get_running_loop()
     if loop is not None:
         current_task = asyncio.Task.current_task(loop)
         if current_task is not None:

azure_functions_worker/testutils.py

@@ -453,7 +453,7 @@ def __init__(self, scripts_dir):
         self._worker = None
 
     async def __aenter__(self):
-        loop = aio_compat.get_running_loop()
+        loop = asyncio._get_running_loop()
         self._host = _MockWebHost(loop, self._scripts_dir)
 
         await self._host.start()
@@ -468,7 +468,7 @@ async def __aenter__(self):
 
         done, pending = await asyncio.wait([self._host._connected_fut,
                                             self._worker_task],
-                                           return_when=asyncio.FIRST_COMPLETED)
+                                            return_when=asyncio.FIRST_COMPLETED)
 
         try:
             if self._worker_task in done: