airflow.providers.standard.operators.latest_only

包含一個運算子,僅針對最新的排程 DagRun 執行下游任務。

模組內容

類別

LatestOnlyOperator

跳過非在最近排程間隔期間執行的任務。

class airflow.providers.standard.operators.latest_only.LatestOnlyOperator(pre_execute=None, post_execute=None, on_execute_callback=None, on_failure_callback=None, on_success_callback=None, on_retry_callback=None, on_skipped_callback=None, **kwargs)[原始碼]

基底類別: airflow.operators.branch.BaseBranchOperator

跳過非在最近排程間隔期間執行的任務。

如果任務在最新的排程間隔之外執行(即 external_trigger),所有直接下游的任務將被跳過。

請注意,如果給定的 DAG_Run 被標記為外部觸發,則下游任務永遠不會被跳過。

ui_color = '#e9ffdb'[原始碼]
choose_branch(context)[原始碼]

選擇要執行哪個分支的抽象方法。

子類別應實作此方法,執行任何必要的邏輯來選擇分支,並傳回 task_id 或 task_id 列表。

參數

context (airflow.utils.context.Context) – 傳遞給 execute() 的上下文字典

此條目是否有幫助?