Remove redundant gen.coroutine hacks

dask · Oct 4, 2023 · 32f5677 · 32f5677
1 parent 336c6ed
commit 32f5677
Showing 1 changed file with 0 additions and 4 deletions.
diff --git a/distributed/deploy/spec.py b/distributed/deploy/spec.py
@@ -388,8 +388,6 @@ async def _correct_state_internal(self) -> None:
                 # *other* workers have finished initialising, so that we can have a
                 # proper teardown.
                 await asyncio.gather(*worker_futs)
-                for w in workers:
-                    await w  # for tornado gen.coroutine support
 
     def _update_worker_status(self, op, msg):
         if op == "remove":
@@ -686,8 +684,6 @@ async def run_spec(spec: dict[str, Any], *args: Any) -> dict[str, Worker | Nanny
 
     if workers:
         await asyncio.gather(*workers.values())
-        for w in workers.values():
-            await w  # for tornado gen.coroutine support
     return workers