More fix

tapis-project · Feb 19, 2024 · 6d339c3 · 6d339c3
1 parent 42aaa31
commit 6d339c3
Showing 1 changed file with 4 additions and 1 deletion.
diff --git 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