airflow.providers.standard.utils.skipmixin¶

属性¶

一个用于跳过任务实例的 Mixin。

airflow.providers.standard.utils.skipmixin.XCOM_SKIPMIXIN_KEY = 'skipmixin_key'[source]¶

airflow.providers.standard.utils.skipmixin.XCOM_SKIPMIXIN_SKIPPED = 'skipped'[source]¶

airflow.providers.standard.utils.skipmixin.XCOM_SKIPMIXIN_FOLLOWED = 'followed'[source]¶

class airflow.providers.standard.utils.skipmixin.SkipMixin(context=None)[source]¶

继承自: airflow.utils.log.logging_mixin.LoggingMixin

一个用于跳过任务实例的 Mixin。

skip(ti, tasks)[source]¶

将相同 DAG 运行中的任务实例设置为跳过。

如果此实例具有 task_id 属性，则将跳过的任务 ID 列表存储到 XCom 中，以便 NotPreviouslySkippedDep 在这些任务被清除时知道它们应该被跳过。

参数:

ti (airflow.sdk.types.RuntimeTaskInstanceProtocol) – 要设置任务为跳过的任务实例
tasks (collections.abc.Iterable[airflow.sdk.definitions._internal.node.DAGNode]) – 要跳过的任务（不是 task_ids）

skip_all_except(ti, branch_task_ids)[source]¶

实现分支算子的逻辑。

给定一个要遵循的单个任务 ID 或任务 ID 列表，这将跳过此算子下游的所有其他任务。

branch_task_ids 被存储到 XCom 中，以便 NotPreviouslySkippedDep 在清除时知道被跳过的任务或新添加的任务应该被跳过。