lambda: Don't be paranoid about exception marshalling

It works
2021-01-24 23:46:40 -08:00
parent c395436ba3
commit 1a3ce59476
1 changed files with 2 additions and 4 deletions
@@ -86,7 +86,7 @@ def process_loop(
        try:
            result = task(args)
        except Exception as e:
-            conn.send((MessageType.exception, str(e)))
+            conn.send((MessageType.exception, e))
            break
        else:
            conn.send((MessageType.result, result))
@@ -180,11 +180,9 @@ def _lambda_pool_impl(
            elif msg_type == MessageType.complete:
                connections.remove(r)
            elif msg_type == MessageType.exception:
-                logger = logging.getLogger(__name__)
-                logger.error(msg)
                for process in processes:
                    process.terminate()
-                raise RuntimeError("Failed")
+                raise msg

    for process in processes:
        process.join()