LatestOnlyOperator

Apache Airflow Certified

Allows a workflow to skip tasks that are not running during the most recent schedule interval.

View on GitHub

Last Updated: Nov. 27, 2022

Access Instructions

Install the Apache Airflow provider package into your Airflow environment.

Import the module into your DAG file and instantiate it with your desired params.

Documentation

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.

Was this page helpful?