原文文档：https://airflow.apache.org/docs/apache-airflow/stable/_api/airflow/operators/latest_only/index.html

  1. from airflow.operators.latest_only import LatestOnlyOperator

This module contains an operator to run downstream tasks only for the latest scheduled DagRun

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.

1. Class Parameters

  • ui_color: #e9ffdb

    2. Functions

    | Functions | Descriptions | | —- | —- | | subprocess_hook |
    |