Begining switch from sp.run -> sp.Popen

openfoam/run/__main__.py

@@ -43,28 +43,66 @@ if not work_dir.exists():
 case_dir = work_dir.joinpath(config.get('main', 'case'))
 if case_dir.exists():
     log.info(f'Deleting case ({case_dir})')
-    sp.run(
-        ('rm', '-r', case_dir)
+    cp = sp.Popen(
+        ('cp', '-r', stl_in, stl_dir),
+        stderr=sp.PIPE,
+        text=True,
     )
+    code = cp.wait()
+    if cp.returncode != 0:
+        log.error(f'Error while copying stl ({stl_in} -> {stl_dir})')
+        log.error(cp.stderr.read()[:-1])
+        sys.exit(code)
+    rm = sp.Popen(
+        ('rm', '-r', case_dir),
+        stdout=sp.PIPE,
+        stderr=sp.PIPE,
+        text=True,
+    )
+    code = rm.wait()
+    if code != 0:
+        log.error(f'Error while deleting case ({case_dir})')
+        log.error(rm.stderr)
+        sys.exit(code)
 
 log.info(f'Copying case ({input_dir} -> {case_dir})')
-sp.run(
-    ('cp', '-r', input_dir, case_dir)
+cp = sp.run(
+    ('cp', '-r', input_dir, case_dir),
+    capture_output=False,
 )
+if cp.returncode != 0:
+    log.error(f'Error while copying case ({input_dir} -> {case_dir})')
+    log.error(cp.stderr)
+    sys.exit(cp.returncode)
 
 if config.getboolean('stl', 'copy', fallback=False):
     stl_dir = case_dir.joinpath('constant', 'triSurface')
     if stl_dir.exists():
         log.info(f'Deleting stl directory ({stl_dir})')
-        sp.run(
-            ('rm', '-r', stl_dir)
+        rm = sp.Popen(
+            ('rm', '-r', stl_dir),
+            stdout=sp.PIPE,
+            stderr=sp.PIPE,
+            text=True,
         )
+        code = rm.wait()
+        if code != 0:
+            log.error(f'Error while deleting stl ({stl_dir})')
+            log.error(rm.stderr.read())
+            sys.exit(code)
 
     stl_in = Path(config.get('stl', 'from')).expanduser()
     log.info(f'Copying stl directory ({stl_in} -> {stl_dir})')
-    sp.run(
-        ('cp', '-r', stl_in, stl_dir)
+    cp = sp.Popen(
+        ('cp', '-r', stl_in, stl_dir),
+        stderr=sp.PIPE,
+        text=True,
     )
+    code = cp.wait()
+    if cp.returncode != 0:
+        log.error(f'Error while copying stl ({stl_in} -> {stl_dir})')
+        log.error(cp.stderr.read()[:-1])
+        sys.exit(code)
 
 if config.getboolean('blockMesh', 'enable', fallback=False):
     log.info('Running blockMesh')
@@ -107,12 +145,17 @@ if config.getboolean('snappyHexMesh', 'enable', fallback=False):
     log.info(f'snappyHexMesh finished successfully')
 
 log.info('Copying 0.org -> 0')
-sp.run(
+cp = sp.run(
     ('cp', '-r',
         case_dir.joinpath('0.org'),
         case_dir.joinpath('0'),
-    )
+    ),
+    capture_output=False,
 )
+if cp.returncode != 0:
+    log.error(f'Error while copying 0.org -> 0')
+    log.error(cp.stderr)
+    sys.exit(cp.returncode)
 
 if config.getboolean('setFields', 'enable', fallback=False):
     log.info('Running setFields')
@@ -202,9 +245,14 @@ if config.getboolean('olaFlow', 'enable', fallback=False):
         log.info(f'Deleting processor directories')
         for proc_dir in case_dir.glob(r'processor*'):
             log.info(f'Deleting {proc_dir}')
-            sp.run(
-                ('rm', '-r', proc_dir)
+            rm = sp.run(
+                ('rm', '-r', proc_dir),
+                capture_output=False,
             )
+            if rm.returncode != 0:
+                log.error(f'Error while deleting processor ({proc_dir})')
+                log.error(rm.stderr)
+                sys.exit(rm.returncode)
 
 _t1 = time()
 log.info(f'Program ended successfully after {timedelta(seconds=_t1-_t0)}')