diff --git a/airflow_ha/operator.py b/airflow_ha/operator.py index 5d554fa..60b7fa8 100644 --- 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