diff --git a/subprocess_adapter.py b/subprocess_adapter.py
index 0a04def..468d6f7 100644
--- a/subprocess_adapter.py
+++ b/subprocess_adapter.py
@@ -70,7 +70,7 @@ def subprocess_operator(cls: Operator, polling_interval=.01) -> Operator:
         try:
             if self.pipe[0].poll():
                 resp = self.pipe[0].recv()
-                assert(isinstance(resp, SubprocessMessage))
+                # assert(isinstance(resp, SubprocessMessage))
             else:
                 resp = None
         except EOFError:
@@ -105,6 +105,7 @@ def subprocess_function(func, *args, pipe, **kwargs):
         except Exception as err:
             log.debug("Caught exception from subprocess: %s", err)
             pipe[1].send(SubprocessMessage(exception=err))
+            raise
         finally:
             pipe[1].close()