Minor

dask · May 18, 2022 · 2564924 · 2564924
1 parent b20105d
commit 2564924
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/distributed/core.py b/distributed/core.py
@@ -685,7 +685,7 @@ async def close(self):
                 break
         await self.rpc.close()
         await asyncio.gather(
-            *(comm.close() for comm in self._comms.values())
+            *(comm.close() for comm in self._comms)
         )  # then forcefully close
         for cb in self._ongoing_coroutines:
             cb.cancel()