Skip to content

Commit

Permalink
improve PID sensitivity
Browse files Browse the repository at this point in the history
  • Loading branch information
gjoseph92 committed Jun 3, 2022
1 parent bd74d2b commit 735d982
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions distributed/tests/test_scheduler.py
Original file line number Diff line number Diff line change
Expand Up @@ -632,7 +632,7 @@ async def test_restart(c, s, a, b):
async def test_restart_some_nannies_some_not(
c: Client, s: Scheduler, a: Nanny, b: Nanny
):
original_pids = await c.run(os.getpid)
original_pids = set((await c.run(os.getpid)).values())
original_workers = dict(s.workers)
async with Worker(s.address, nthreads=1) as w:
await c.wait_for_workers(3)
Expand Down Expand Up @@ -667,7 +667,7 @@ def restart(self, scheduler: Scheduler) -> None:

assert len(s.workers) == 2
# Confirm they restarted
new_pids = await c.run(os.getpid)
new_pids = set((await c.run(os.getpid)).values())
assert new_pids != original_pids
# The workers should have new addresses
assert s.workers.keys().isdisjoint(original_workers.keys())
Expand Down

0 comments on commit 735d982

Please sign in to comment.