`airflow.operators.subdag`¶

此模組已棄用。請使用 airflow.utils.task_group。

此模組提供巢狀 DAG 以及複雜程度分層的方式。

模組內容¶

`SkippedStatePropagationOptions`	子 DAG 的任務略過狀態傳播至父 DAG 任務的可選選項。
`SubDagOperator`	此類別已棄用，請使用 `airflow.utils.task_group.TaskGroup`。

class airflow.operators.subdag.SkippedStatePropagationOptions[原始碼]¶

基底類別： enum.Enum

子 DAG 的任務略過狀態傳播至父 DAG 任務的可選選項。

class airflow.operators.subdag.SubDagOperator(*, subdag, session=NEW_SESSION, conf=None, propagate_skipped_state=None, **kwargs)[原始碼]¶

此類別已棄用，請使用 airflow.utils.task_group.TaskGroup。

這會執行子 DAG。依照慣例，子 DAG 的 dag_id 應以其父 DAG 和點號作為前綴。如 parent.child。雖然 SubDagOperator 可以佔用池/並行槽，但使用者可以指定 mode=reschedule，以便定期釋放槽，以避免潛在的死鎖。

參數

subdag (airflow.models.dag.DAG) – 要作為目前 DAG 子 DAG 執行的 DAG 物件。
session (sqlalchemy.orm.session.Session) – sqlalchemy 工作階段
conf (dict | None) – 子 DAG 的組態
propagate_skipped_state (SkippedStatePropagationOptions | None) – 透過設定此引數，您可以定義是否應將葉節點任務的略過狀態傳播到父 DAG 的下游任務。

poke(context)[原始碼]¶

衍生此類別時覆寫。

post_execute(context, result=None)[原始碼]¶

在呼叫 self.execute() 之後立即執行。

它會傳遞執行環境以及運算子傳回的任何結果。