Skip to content

Commit

Permalink
Remove test_reconnect
Browse files Browse the repository at this point in the history
We've removed this functionality for now
  • Loading branch information
mrocklin committed Apr 28, 2022
1 parent a0721aa commit b59ccd0
Showing 1 changed file with 0 additions and 28 deletions.
28 changes: 0 additions & 28 deletions distributed/cli/tests/test_dask_worker.py
Original file line number Diff line number Diff line change
Expand Up @@ -297,34 +297,6 @@ async def test_no_reconnect(c, s, nanny):
assert worker.returncode == 0


@pytest.mark.slow
@pytest.mark.parametrize("nanny", ["--nanny", "--no-nanny"])
@gen_cluster(client=True, nthreads=[])
async def test_reconnect(c, s, nanny):
with popen(
[
"dask-worker",
s.address,
"--reconnect",
nanny,
"--no-dashboard",
]
) as worker:
# roundtrip works
assert await c.submit(lambda x: x + 1, 10) == 11

(comm,) = s.stream_comms.values()
comm.abort()

# roundtrip still works, which means the worker reconnected
assert await c.submit(lambda x: x + 1, 11) == 12

# closing the scheduler cleanly does terminate the worker
await s.close()
await to_thread(worker.wait, timeout=5)
assert worker.returncode == 0


@pytest.mark.slow
@gen_cluster(client=True, nthreads=[])
async def test_resources(c, s):
Expand Down

0 comments on commit b59ccd0

Please sign in to comment.