Only close scheduler in SpecCluster if it exists (#6888)

dask · Aug 17, 2022 · 1d0701b · 1d0701b
1 parent 3647cfe
commit 1d0701b
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/distributed/deploy/spec.py b/distributed/deploy/spec.py
@@ -431,7 +431,8 @@ async def _close(self):
             else:
                 logger.warning("Cluster closed without starting up")
 
-            await self.scheduler.close()
+            if self.scheduler:
+                await self.scheduler.close()
             for w in self._created:
                 assert w.status in {
                     Status.closing,