From c0ff6af8666bdec6a379e81e5a1b34b9a94eb988 Mon Sep 17 00:00:00 2001 From: Ari Brown Date: Wed, 15 Nov 2023 15:09:18 -0500 Subject: [PATCH] specifying port for worker dashboard --- minerva/cluster.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/minerva/cluster.py b/minerva/cluster.py index 5d3365b..e91564e 100644 --- a/minerva/cluster.py +++ b/minerva/cluster.py @@ -64,7 +64,8 @@ class Cluster: def start_dask(self): self.scheduler.cmd("dask scheduler &> /tmp/scheduler.log", disown=True) for w in self.workers: - w.cmd(f"dask worker {self.private_location} &> /tmp/worker.log", disown=True) + dash = 50000 + w.variables['number'] + w.cmd(f"dask worker {self.private_location} --dashboard-address {dash} &> /tmp/worker.log", disown=True) def terminate(self):