airflow.operators.latest_only
¶
This module contains an operator to run downstream tasks only for the latest scheduled DagRun
Module Contents¶
-
class
airflow.operators.latest_only.
LatestOnlyOperator
[source]¶ Bases:
airflow.operators.branch.BaseBranchOperator
Allows a workflow to skip tasks that are not running during the most recent schedule interval.
If the task is run outside of the latest schedule interval (i.e. external_trigger), all directly downstream tasks will be skipped.
Note that downstream tasks are never skipped if the given DAG_Run is marked as externally triggered.