VMCluster should name wokers based on SpecCluster new_worker_name() (#…

…325)
dask · Dec 8, 2021 · f9c3272 · f9c3272
1 parent 4d2d9ea
commit f9c3272
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/dask_cloudprovider/generic/vmcluster.py b/dask_cloudprovider/generic/vmcluster.py
@@ -323,7 +323,9 @@ async def _start(
             "options": self.scheduler_options,
         }
         self.new_spec = {"cls": self.worker_class, "options": self.worker_options}
-        self.worker_spec = {i: self.new_spec for i in range(self._n_workers)}
+        self.worker_spec = {
+            self._new_worker_name(i): self.new_spec for i in range(self._n_workers)
+        }
 
         with warn_on_duration(
             "10s",