diff --git a/src/main/java/org/openrewrite/polyglot/RemoteProgressBarReceiver.java b/src/main/java/org/openrewrite/polyglot/RemoteProgressBarReceiver.java index 7cac3b4..f79c35a 100644 --- a/src/main/java/org/openrewrite/polyglot/RemoteProgressBarReceiver.java +++ b/src/main/java/org/openrewrite/polyglot/RemoteProgressBarReceiver.java @@ -66,6 +66,11 @@ protected boolean removeEldestEntry(Map.Entry eldes } switch (message.getType()) { + case Exception: + if (message.getMessage() != null) { + throw RemoteException.decode(message.getMessage()); + } + break; case IntermediateResult: delegate.intermediateResult(message.getMessage()); break;