airflow.providers.standard.operators.latest_only¶

包含一个操作符，用于仅针对最新的调度 DagRun 运行下游任务。

类¶

跳过不在最新调度周期内运行的任务。

class airflow.providers.standard.operators.latest_only.LatestOnlyOperator(**kwargs)[source]¶

跳过不在最新调度周期内运行的任务。

如果任务在最新调度周期之外运行（即 run_type == DagRunType.MANUAL），则所有直接下游任务将被跳过。

请注意，如果给定的 DAG_Run 被标记为外部触发，则下游任务永远不会被跳过。

请注意，当与产生零长度或时间点数据区间的时间表（例如 DeltaTriggerTimetable）一起使用时，此操作符假定每次运行都是最新的，并且不会跳过下游任务。

choose_branch(context)[source]¶

选择要运行的分支的抽象方法。

子类应该实现此方法，运行必要的逻辑来选择分支，并返回一个 task_id 或 task_id 列表。

参数:: context (airflow.sdk.definitions.context.Context) – 传递给 execute() 方法的上下文字典。