diff --git a/src/engine/src/core/workflows/executors/WorkflowExecutor.py b/src/engine/src/core/workflows/executors/WorkflowExecutor.py index 6975351f..d1b0ce7f 100644 --- a/src/engine/src/core/workflows/executors/WorkflowExecutor.py +++ b/src/engine/src/core/workflows/executors/WorkflowExecutor.py @@ -541,7 +541,7 @@ def _task_is_ready(self, task): # We check the failed tasks list because some tasks are permitted to # fail if all of their dependencies specify can_fail = True for dep in task.depends_on: - if dep.id not in self.state.finished or dep.id not in self.state.failed: + if dep.id not in self.state.finished and dep.id not in self.state.failed: return False return True