get loop from fixture

dask · Nov 10, 2022 · 9caefe4 · 9caefe4
1 parent c8fe046
commit 9caefe4
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/distributed/tests/test_client.py b/distributed/tests/test_client.py
@@ -6593,9 +6593,9 @@ async def test_as_completed_condition_loop(c, s, a, b):
     sys.version_info >= (3, 10),
     reason="On Py3.10+ semaphore._loop is not bound until .acquire() blocks",
 )
-def test_client_connectionpool_semaphore_loop(s, a, b):
-    with Client(s["address"]) as c:
-        assert c.rpc.semaphore._loop is c.loop.asyncio_loop
+def test_client_connectionpool_semaphore_loop(s, a, b, loop):
+    with Client(s["address"], loop=loop) as c:
+        assert c.rpc.semaphore._loop is loop
 
 
 @pytest.mark.slow