From 25b0360bedb76de1f6c7b5a1a64847406a1ee9a8 Mon Sep 17 00:00:00 2001 From: Ari Brown Date: Wed, 15 Nov 2023 14:55:16 -0500 Subject: [PATCH] dask worker logs now written to disk hopefully --- minerva/cluster.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/minerva/cluster.py b/minerva/cluster.py index 0c94dfb..5d3365b 100644 --- a/minerva/cluster.py +++ b/minerva/cluster.py @@ -62,9 +62,9 @@ class Cluster: # Start the dask processes necessary for cluster communication def start_dask(self): - self.scheduler.cmd("dask scheduler 2&>1 > /tmp/scheduler.log", disown=True) + self.scheduler.cmd("dask scheduler &> /tmp/scheduler.log", disown=True) for w in self.workers: - w.cmd(f"dask worker {self.private_location} 2&>1 > /tmp/worker.log", disown=True) + w.cmd(f"dask worker {self.private_location} &> /tmp/worker.log", disown=True) def terminate(self):