From 10bcd367f6b271a11ecd2a592d3b51818a9d55bc Mon Sep 17 00:00:00 2001
From: Ari Brown <ari@airintech.com>
Date: Wed, 15 Nov 2023 14:50:03 -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 cc8d971..0c94dfb 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", disown=True)
+        self.scheduler.cmd("dask scheduler 2&>1 > /tmp/scheduler.log", disown=True)
         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):