.

cycled_exp.py

@@ -7,7 +7,7 @@ if __name__ == "__main__":
     """
     Run a cycled OSSE with WRF and DART.
     """
-    w = WorkFlows(exp_config='cfg.py', server_config='jet.py')
+    w = WorkFlows(exp_config='cfg.py', server_config='srvx1.py')
 
     timedelta_integrate = dt.timedelta(minutes=15)
     timedelta_btw_assim = dt.timedelta(minutes=15)
@@ -15,7 +15,7 @@ if __name__ == "__main__":
     id = None
 
     if False:  # warm bubble
-        prior_path_exp = '/jetfs/home/lkugler/data/sim_archive/exp_v1.19_P3_wbub7_noDA'
+        prior_path_exp = '/jetfs/scratch/lkugler/data/sim_archive/exp_v1.19_P3_wbub7_noDA'
 
         init_time = dt.datetime(2008, 7, 30, 12)
         time = dt.datetime(2008, 7, 30, 12, 30)
@@ -27,7 +27,7 @@ if __name__ == "__main__":
         # id = w.wrfinput_insert_wbubble(depends_on=id)    
 
     if True:  # random
-        prior_path_exp = '/jetfs/home/lkugler/data/sim_archive/exp_v1.19_P2_noDA'
+        prior_path_exp = '/mnt/jetfs/scratch/lkugler/data/sim_archive/exp_v1.19_P2_noDA'
 
         init_time = dt.datetime(2008, 7, 30, 12)
         time = dt.datetime(2008, 7, 30, 13)

dartwrf/utils.py

@@ -70,7 +70,9 @@ class ClusterConfig(object):
                   ).run(cmd, depends_on=depends_on)
         else:
             print(cmd)
-            os.system(cmd)
+            returncode = os.system(cmd)
+            if returncode != 0:
+                raise Exception('Error running command: '+cmd)
 
 userhome = os.path.expanduser('~')