Update distributed/tests/test_client.py

dask · Mar 23, 2022 · 7754b00 · 7754b00
1 parent 3d0805d
commit 7754b00
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/distributed/tests/test_client.py b/distributed/tests/test_client.py
@@ -6465,6 +6465,7 @@ async def f(stacklevel, mode=None):
 async def test_as_completed_condition_loop(c, s, a, b):
     seq = c.map(inc, range(5))
     ac = as_completed(seq)
+    # consume the ac so that the ac.condition is bound to the loop on py3.10+
     async for _ in ac:
         pass
     assert ac.condition._loop == c.loop.asyncio_loop