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.

ui_color = #e9ffdb[source]
choose_branch(self, context: Dict)[source]

Was this entry helpful?