ari/minerva
1
0
Fork 0
forked from bellwether/minerva
Code Pull requests Activity

dask worker logs now written to disk hopefully

Browse source
This commit is contained in:
Ari Brown 2023-11-15 14:50:03 -05:00
parent 239abf8fc1
commit 10bcd367f6
1 changed files with 2 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

4
minerva/cluster.py
View file

@ -62,9 +62,9 @@ class Cluster:
# Start the dask processes necessary for cluster communication # Start the dask processes necessary for cluster communication
def start_dask(self): def start_dask(self):
self.scheduler.cmd("dask-scheduler", disown=True) self.scheduler.cmd("dask scheduler 2&>1 > /tmp/scheduler.log", disown=True)
for w in self.workers: for w in self.workers:
w.cmd(f"dask-worker {self.scheduler.private_ip}:8786", disown=True) w.cmd(f"dask worker {self.private_location} 2&>1 > /tmp/worker.log", disown=True)
def terminate(self): def terminate(self):