From 9caefe431a7f6bfd8033215d40ed1cb5513d397a Mon Sep 17 00:00:00 2001 From: Thomas Grainger Date: Thu, 10 Nov 2022 15:01:59 +0000 Subject: [PATCH] get loop from fixture --- distributed/tests/test_client.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/distributed/tests/test_client.py b/distributed/tests/test_client.py index b5cb7fc1b31..9ea99777077 100644 --- 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