airflow.operators.latest_only_operator

Module Contents

class airflow.operators.latest_only_operator.LatestOnlyOperator[source]

Bases: airflow.models.BaseOperator, airflow.models.SkipMixin

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, 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]
execute(self, context)[source]

Was this entry helpful?