airflow.providers.standard.operators.latest_only
¶
包含一個運算子,僅針對最新的排程 DagRun 執行下游任務。
模組內容¶
類別¶
跳過非在最近排程間隔期間執行的任務。 |
- 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 被標記為外部觸發,則下游任務永遠不會被跳過。