More on the right number of DIMs

ICRAR · Dec 15, 2021 · 1c1fe8f · 1c1fe8f
1 parent 7e959ee
commit 1c1fe8f
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/daliuge-engine/dlg/deploy/start_dlg_cluster.py b/daliuge-engine/dlg/deploy/start_dlg_cluster.py
@@ -622,6 +622,7 @@ def main():
         logger.debug("Dumping list of nodes to %s", nodesfile)
         with open(nodesfile, "wt") as f:
             f.write("\n".join(remote.sorted_peers))
+        start_dim(remote.nm_ips, log_dir, remote.my_ip, logv=logv)
 
     dim_proc = None
     # start the NM
@@ -649,6 +650,7 @@ def main():
                     "Couldn't connect to the main drop manager, proxy not started"
                 )
         else:
+            logger.info(f"Starting island managers on nodes: {remote.dim_ips}")
             if remote.my_ip in remote.dim_ips:
                 dim_proc = start_dim(remote.nm_ips, log_dir, remote.my_ip, logv=logv)