From d82eb08fceb6d28045401e8edf48fa8792207e30 Mon Sep 17 00:00:00 2001 From: Hendrik Makait Date: Wed, 2 Aug 2023 16:52:06 +0200 Subject: [PATCH 1/2] Remove terminate RPC --- distributed/worker.py | 1 - 1 file changed, 1 deletion(-) diff --git a/distributed/worker.py b/distributed/worker.py index 9e6cb988cb5..aef329801e2 100644 --- a/distributed/worker.py +++ b/distributed/worker.py @@ -684,7 +684,6 @@ def __init__( "get_data": self.get_data, "update_data": self.update_data, "free_keys": self._handle_remote_stimulus(FreeKeysEvent), - "terminate": self.close, "ping": pingpong, "upload_file": self.upload_file, "call_stack": self.get_call_stack, From f3db2edd04589efc860347a36fa82d2f93e9756b Mon Sep 17 00:00:00 2001 From: Hendrik Makait Date: Wed, 2 Aug 2023 17:16:25 +0200 Subject: [PATCH 2/2] Remove test for terminate --- distributed/tests/test_nanny.py | 13 ------------- 1 file changed, 13 deletions(-) diff --git a/distributed/tests/test_nanny.py b/distributed/tests/test_nanny.py index 26719a34cde..7582e30a5c5 100644 --- a/distributed/tests/test_nanny.py +++ b/distributed/tests/test_nanny.py @@ -448,19 +448,6 @@ def remove_worker(self, **kwargs): await event.wait() -@gen_cluster(client=True, nthreads=[]) -async def test_nanny_closes_cleanly_if_worker_is_terminated(c, s): - async with Nanny(s.address) as n: - async with c.rpc(n.worker_address) as w: - IOLoop.current().add_callback(w.terminate) - start = time() - while n.status != Status.closed: - await asyncio.sleep(0.01) - assert time() < start + 5 - - assert n.status == Status.closed - - @gen_cluster(client=True, nthreads=[]) async def test_config(c, s): async with Nanny(s.address, config={"foo": "bar"}) as n: