Fix exception handling in local executor [ci fast]

Signed-off-by: Paolo Di Tommaso <paolo.ditommaso@gmail.com>
nextflow-io · Apr 5, 2024 · 74d7d7a · 74d7d7a
1 parent 01447d5
commit 74d7d7a
Showing 1 changed file with 8 additions and 3 deletions.
diff --git a/modules/nextflow/src/main/groovy/nextflow/executor/local/NativeTaskHandler.groovy b/modules/nextflow/src/main/groovy/nextflow/executor/local/NativeTaskHandler.groovy
@@ -17,6 +17,7 @@
 
 package nextflow.executor.local
 
+import java.lang.reflect.InvocationTargetException
 import java.util.concurrent.Callable
 import java.util.concurrent.Future
 
@@ -91,11 +92,15 @@ class NativeTaskHandler extends TaskHandler {
     boolean checkIfCompleted() {
         if( isRunning() && result.isDone() ) {
             status = TaskStatus.COMPLETED
-            if( result.get() instanceof Throwable ) {
-                task.error = (Throwable)result.get()
+            final ret = result.get()
+            if( ret instanceof InvocationTargetException ) {
+                task.error = ret.cause
+            }
+            else if( ret instanceof Throwable ) {
+                task.error = (Throwable)ret
             }
             else {
-                task.stdout = result.get()
+                task.stdout = ret
             }
             return true
         }