diff --git a/src/engine/src/core/workflows/executors/WorkflowExecutor.py b/src/engine/src/core/workflows/executors/WorkflowExecutor.py
index 4e9abc35..4f46d327 100644
--- a/src/engine/src/core/workflows/executors/WorkflowExecutor.py
+++ b/src/engine/src/core/workflows/executors/WorkflowExecutor.py
@@ -459,7 +459,7 @@ def _set_tasks(self, tasks):
                     parent_can_fail_flags.append(dep.can_fail)
 
                 # If the length of can_fail_flags == 0, then this task has no child tasks
-                child_task.can_fail = False if len(parent_can_fail_flags) == 0 else all(parent_can_fail_flags)
+                parent_task.can_fail = False if len(parent_can_fail_flags) == 0 else all(parent_can_fail_flags)
         except Exception as e:
             raise Exception(f"Error resolving can_fail flag for parent task '{parent_task_id}': {e}")