diff --git a/src/engine/src/core/workflows/WorkflowExecutor.py b/src/engine/src/core/workflows/WorkflowExecutor.py
index fa38bb58..f64c5f15 100644
--- a/src/engine/src/core/workflows/WorkflowExecutor.py
+++ b/src/engine/src/core/workflows/WorkflowExecutor.py
@@ -335,7 +335,10 @@ def _start_task(self, task):
                 self.state.ctx.logger.info(self.t_str(task, "FAILED"))
                 self.publish(Event(TASK_FAILED, self.state.ctx, task=task))
                 # Get the next queued tasks if any
-                unstarted_threads = self._on_task_terminal_state(task, task_result)
+                unstarted_threads = self._on_task_terminal_state(
+                    task,
+                    TaskResult(1, errors=[str(e)])
+                )
 
                 # NOTE Triggers hook _on_change_ready_task
                 self.state.ready_tasks += unstarted_threads