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 在清除時知道被跳過的任務或新新增的任務應該被跳過。