Importing and fixing typo on RemoteExceptionWrapper (#1021)

This breakage was introduced by PR #993
Parsl · Jun 6, 2019 · a6ad19fe2405fd5a4e0961a0b27139b18b8115e9 · a6ad19f
1 parent 4c32c46
commit a6ad19fe2405fd5a4e0961a0b27139b18b8115e9
Unified Split

Showing with 2 additions and 1 deletion.

+2 −1 parsl/executors/high_throughput/executor.py
diff --git a/parsl/executors/high_throughput/executor.py b/parsl/executors/high_throughput/executor.py
@@ -13,6 +13,7 @@
 from ipyparallel.serialize import pack_apply_message  # ,unpack_apply_message
 from ipyparallel.serialize import deserialize_object  # ,serialize_object
+  
+from parsl.app.errors import RemoteExceptionWrapper
 from parsl.executors.high_throughput import zmq_pipes
 from parsl.executors.high_throughput import interchange
 from parsl.executors.errors import *
@@ -362,7 +363,7 @@ def _queue_management_worker(self):
                            try:
                                s, _ = deserialize_object(msg['exception'])
                                # s should be a RemoteExceptionWrapper... so we can reraise it
-  
-                                if isinstance(s, RemoteExceptionWapper):
+  
+                                if isinstance(s, RemoteExceptionWrapper):
                                    try:
                                        s.reraise()
                                    except Exception as e: