From 6d339c39271ac300b055db55dd29dad6811dcd56 Mon Sep 17 00:00:00 2001 From: Nathan Freeman Date: Mon, 19 Feb 2024 14:31:13 -0600 Subject: [PATCH] More fix --- src/engine/src/core/workflows/WorkflowExecutor.py | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) 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