remove warnings using the async loop fixture

Author: sanderegg

packages/service-library/tests/test_pools.py

@@ -1,4 +1,4 @@
-from asyncio import BaseEventLoop
+import asyncio
 from concurrent.futures import ProcessPoolExecutor
 
 from servicelib.pools import (
@@ -11,17 +11,25 @@ def return_int_one() -> int:
     return 1
 
 
-async def test_default_thread_pool_executor(event_loop: BaseEventLoop) -> None:
-    assert await event_loop.run_in_executor(None, return_int_one) == 1
+async def test_default_thread_pool_executor() -> None:
+    assert await asyncio.get_running_loop().run_in_executor(None, return_int_one) == 1
 
 
-async def test_blocking_process_pool_executor(event_loop: BaseEventLoop) -> None:
-    assert await event_loop.run_in_executor(ProcessPoolExecutor(), return_int_one) == 1
+async def test_blocking_process_pool_executor() -> None:
+    assert (
+        await asyncio.get_running_loop().run_in_executor(
+            ProcessPoolExecutor(), return_int_one
+        )
+        == 1
+    )
 
 
-async def test_non_blocking_process_pool_executor(event_loop: BaseEventLoop) -> None:
+async def test_non_blocking_process_pool_executor() -> None:
     with non_blocking_process_pool_executor() as executor:
-        assert await event_loop.run_in_executor(executor, return_int_one) == 1
+        assert (
+            await asyncio.get_running_loop().run_in_executor(executor, return_int_one)
+            == 1
+        )
 
 
 async def test_same_pool_instances() -> None:
@@ -36,9 +44,12 @@ async def test_different_pool_instances() -> None:
         assert first != second
 
 
-async def test_non_blocking_thread_pool_executor(event_loop: BaseEventLoop) -> None:
+async def test_non_blocking_thread_pool_executor() -> None:
     with non_blocking_thread_pool_executor() as executor:
-        assert await event_loop.run_in_executor(executor, return_int_one) == 1
+        assert (
+            await asyncio.get_running_loop().run_in_executor(executor, return_int_one)
+            == 1
+        )
 
 
 async def test_same_thread_pool_instances() -> None: