From a5600f5e045aa444096aabfde889b99890633c4f Mon Sep 17 00:00:00 2001 From: Nathan Freeman Date: Tue, 14 Nov 2023 17:04:46 -0600 Subject: [PATCH] bugfix --- src/engine/src/core/workflows/executors/WorkflowExecutor.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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