From d25a5486afca95b203ed6e127bdac6d3b8fba699 Mon Sep 17 00:00:00 2001 From: Maxim Lippeveld Date: Tue, 21 May 2024 19:34:34 +0000 Subject: [PATCH] Pass port to localcluster --- src/scip/utils/util.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/scip/utils/util.py b/src/scip/utils/util.py index dea2b36..1f4f2e1 100644 --- 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":