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 被标记为外部触发，则下游任务永远不会被跳过。