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() 方法的上下文字典。