From 73e75e578cd43ab5533a53e08ff955f5bfb0865a Mon Sep 17 00:00:00 2001 From: fjetter Date: Wed, 9 Aug 2023 16:30:00 +0200 Subject: [PATCH] leftover --- distributed/tests/test_worker.py | 1 - distributed/utils_test.py | 4 ---- 2 files changed, 5 deletions(-) diff --git a/distributed/tests/test_worker.py b/distributed/tests/test_worker.py index b2a3b158724..4422e2dd517 100644 --- a/distributed/tests/test_worker.py +++ b/distributed/tests/test_worker.py @@ -3617,7 +3617,6 @@ async def test_execute_preamble_abort_retirement(c, s): """ async with BlockedExecute(s.address) as a: await c.wait_for_workers(1) - a.block_deserialize_task.set() # Uninteresting in this test x = await c.scatter({"x": 1}, workers=[a.address]) y = c.submit(inc, 1, key="y", workers=[a.address]) diff --git a/distributed/utils_test.py b/distributed/utils_test.py index 2d32ae07513..8fc4ec4d38f 100644 --- a/distributed/utils_test.py +++ b/distributed/utils_test.py @@ -2253,10 +2253,6 @@ class BlockedExecute(Worker): method and then does not proceed, thus leaving the task in executing state indefinitely, until the test sets `block_execute`. - After that, the worker sets `in_deserialize_task` to simulate the moment when a - large run_spec is being deserialized in a separate thread. The worker will block - again until the test sets `block_deserialize_task`. - Finally, the worker sets `in_execute_exit` when execute() terminates, but before the worker state has processed its exit callback. The worker will block one last time until the test sets `block_execute_exit`.