`airflow.operators.subdag`¶

此模块已弃用。请使用 airflow.utils.task_group。

该模块提供了一种嵌套 DAG 的方法，从而实现复杂的层次结构。

模块内容¶

`SkippedStatePropagationOptions`	子 DAG 任务的跳过状态传播到父 DAG 任务的可用选项。
`SubDagOperator`	此类已弃用，请使用 `airflow.utils.task_group.TaskGroup`。

class airflow.operators.subdag.SkippedStatePropagationOptions[源代码]¶

子 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 应以其父级和点号作为前缀。如 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() 后立即执行。

它传递执行上下文和操作符返回的任何结果。