Merge pull request #41 from airflow-laminar/tkp/trig

Make decision operator have none_skipped trigger rule
airflow-laminar · Feb 19, 2025 · ee67c74 · ee67c74
2 parents 8f19efe + 98ff65e
commit ee67c74
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/airflow_ha/operator.py b/airflow_ha/operator.py
@@ -171,6 +171,8 @@ def __init__(
             task_id=f"{self.task_id}-decide",
             python_callable=choose_branch,
             provide_context=True,
+            # NOTE: use none_skipped here as the sensor will fail in a timeout
+            trigger_rule="none_skipped",
         )
 
         self >> self._decide_task