diff --git a/packages/backend/src/graphql/mutations/execute-flow.ts b/packages/backend/src/graphql/mutations/execute-flow.ts
index dfcd726a..f9eb3740 100644
--- a/packages/backend/src/graphql/mutations/execute-flow.ts
+++ b/packages/backend/src/graphql/mutations/execute-flow.ts
@@ -24,7 +24,7 @@ const executeFlow = async (
 
   const flow = await untilStep.$relatedQuery('flow');
 
-  const data = await new Processor(flow, {
+  const executionStep = await new Processor(flow, {
     untilStep,
     testRun: true,
   }).run();
@@ -33,7 +33,11 @@ const executeFlow = async (
     status: 'completed',
   });
 
-  return { data, step: untilStep };
+  if (executionStep.errorDetails) {
+    throw new Error(JSON.stringify(executionStep.errorDetails, null, 2));
+  }
+
+  return { data: executionStep.dataOut, step: untilStep };
 };
 
 export default executeFlow;
diff --git a/packages/backend/src/services/processor.ts b/packages/backend/src/services/processor.ts
index a56e8753..21d58db6 100644
--- a/packages/backend/src/services/processor.ts
+++ b/packages/backend/src/services/processor.ts
@@ -160,11 +160,7 @@ class Processor {
       .orderBy('created_at', 'desc')
       .first();
 
-    if (lastExecutionStepFromFirstExecution.errorDetails) {
-      return lastExecutionStepFromFirstExecution.errorDetails;
-    } else {
-      return lastExecutionStepFromFirstExecution?.dataOut;
-    }
+    return lastExecutionStepFromFirstExecution;
   }
 
   async getInitialTriggerData(step: Step) {