.

airflow-laminar · Aug 24, 2024 · bab2576 · bab2576
1 parent 55522e9
commit bab2576
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/airflow_ha/operator.py b/airflow_ha/operator.py
@@ -136,11 +136,13 @@ def check(self) -> Operator:
 
     @property
     def failed(self) -> Operator:
-        return self._end_fail
+        # NOTE: use loop_fail as this will pass, but self._end_fail will fail to mark the DAG failed
+        return self._loop_fail
 
     @property
     def passed(self) -> Operator:
-        return self._end_pass
+        # NOTE: use loop_pass here to match failed()
+        return self._loop_pass
 
     @property
     def done(self) -> Operator: