raise exception on any non-zero exit code from subprocesses (#492)

* raise exception on any non-zero exit code from subprocesses Co-authored-by: abelsonlive <[email protected]>
pystorm · Jan 10, 2022 · 95cb598 · 95cb598
1 parent fb8ce9c
commit 95cb598
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 4 deletions.
diff --git a/streamparse/util.py b/streamparse/util.py
@@ -592,6 +592,12 @@ def set_topology_serializer(env_config, config, topology_class):
 
 def run_cmd(cmd, user, **kwargs):
     with show("everything"):
-        return (
-            run(cmd, **kwargs) if user == env.user else sudo(cmd, user=user, **kwargs)
-        )
+        with settings(warn_only=True):
+            command_result = (
+                run(cmd, **kwargs)
+                if user == env.user
+                else sudo(cmd, user=user, **kwargs)
+            )
+    if command_result.return_code != 0:
+        raise RuntimeError('Command failed to run: %s' % cmd)
+    return command_result
diff --git a/streamparse/version.py b/streamparse/version.py
@@ -28,5 +28,5 @@ def _safe_int(string):
         return string
 
 
-__version__ = "4.1.1"
+__version__ = "4.1.2"
 VERSION = tuple(_safe_int(x) for x in __version__.split("."))