Skip to content

Commit

Permalink
remove test_client_connectionpool_semaphore_loop and test_client_gath…
Browse files Browse the repository at this point in the history
…er_semaphore_loop

on py3.10 an asyncio.Semaphore doesn't bind to a loop until acquire()
is called when the limit is 0
  • Loading branch information
graingert committed Mar 16, 2022
1 parent 69f2a97 commit 972921f
Showing 1 changed file with 0 additions and 17 deletions.
17 changes: 0 additions & 17 deletions distributed/tests/test_client.py
Original file line number Diff line number Diff line change
Expand Up @@ -6461,15 +6461,6 @@ async def f(stacklevel, mode=None):
assert "cdn.bokeh.org" in data


@pytest.mark.skipif(
sys.version_info >= (3, 10), reason="No internal loop in Python 3.10"
)
@gen_cluster(nthreads=[])
async def test_client_gather_semaphore_loop(s):
async with Client(s.address, asynchronous=True) as c:
assert c._gather_semaphore._loop is c.loop.asyncio_loop


@gen_cluster(client=True)
async def test_as_completed_condition_loop(c, s, a, b):
seq = c.map(inc, range(5))
Expand All @@ -6479,14 +6470,6 @@ async def test_as_completed_condition_loop(c, s, a, b):
assert ac.condition._loop == c.loop.asyncio_loop


@pytest.mark.skipif(
sys.version_info >= (3, 10), reason="No internal loop in Python 3.10"
)
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


@pytest.mark.slow
@gen_cluster(nthreads=[], timeout=60)
async def test_mixed_compression(s):
Expand Down

0 comments on commit 972921f

Please sign in to comment.