Wrap checked exception from PluginClient

dbwiddis · dbwiddis · commit 190254728804 · 2025-11-07T12:11:19.000-08:00
Signed-off-by: Daniel Widdis &lt;widdis@gmail.com&gt;
diff --git a/src/main/java/org/opensearch/flowframework/util/PluginClient.java b/src/main/java/org/opensearch/flowframework/util/PluginClient.java
@@ -10,6 +10,7 @@
 
 import org.apache.logging.log4j.LogManager;
 import org.apache.logging.log4j.Logger;
+import org.opensearch.ExceptionsHelper;
 import org.opensearch.action.ActionRequest;
 import org.opensearch.action.ActionType;
 import org.opensearch.common.util.concurrent.ThreadContext;
@@ -54,6 +55,8 @@ protected <Request extends ActionRequest, Response extends ActionResponse> void
                 logger.info("Running transport action with subject: {}", subject.getPrincipal().getName());
                 super.doExecute(action, request, ActionListener.runBefore(listener, ctx::restore));
             });
+        } catch (Exception e) {
+            throw ExceptionsHelper.convertToRuntime(e);
         }
     }
 }

Original file line number	Diff line number	Diff line change
`@@ -10,6 +10,7 @@`
`10`	`10`
`11`	`11`	`import org.apache.logging.log4j.LogManager;`
`12`	`12`	`import org.apache.logging.log4j.Logger;`
	`13`	`+import org.opensearch.ExceptionsHelper;`
`13`	`14`	`import org.opensearch.action.ActionRequest;`
`14`	`15`	`import org.opensearch.action.ActionType;`
`15`	`16`	`import org.opensearch.common.util.concurrent.ThreadContext;`
`@@ -54,6 +55,8 @@ protected <Request extends ActionRequest, Response extends ActionResponse> void`
`54`	`55`	`logger.info("Running transport action with subject: {}", subject.getPrincipal().getName());`
`55`	`56`	`super.doExecute(action, request, ActionListener.runBefore(listener, ctx::restore));`
`56`	`57`	`});`
	`58`	`+ } catch (Exception e) {`
	`59`	`+ throw ExceptionsHelper.convertToRuntime(e);`
`57`	`60`	`}`
`58`	`61`	`}`
`59`	`62`	`}`