Pass port to localcluster

ScalableCytometryImageProcessing · May 21, 2024 · d25a548 · d25a548
1 parent 21ed458
commit d25a548
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/scip/utils/util.py b/src/scip/utils/util.py
@@ -72,7 +72,7 @@ def __enter__(self):
             with dask.config.set({"distributed.worker.resources.cellpose": 1}):
                 self.cluster = LocalCluster(
                     n_workers=self.n_workers, threads_per_worker=self.threads_per_process,
-                    processes=True
+                    processes=True, dashboard_address=f":{self.port}"
                 )
             self.client = Client(self.cluster)
         elif self.mode == "jobqueue":