airflow.operators.subdag

This module is deprecated. Please use airflow.utils.task_group.

The module which provides a way to nest your DAGs and so your levels of complexity.

Module Contents

Classes

SkippedStatePropagationOptions

Available options for skipped state propagation of subdag's tasks to parent dag tasks.

SubDagOperator

This class is deprecated, please use airflow.utils.task_group.TaskGroup.
class airflow.operators.subdag.SkippedStatePropagationOptions[source]

Bases: enum.Enum

Available options for skipped state propagation of subdag’s tasks to parent dag tasks.

ALL_LEAVES = 'all_leaves'[source]
ANY_LEAF = 'any_leaf'[source]
class airflow.operators.subdag.SubDagOperator(*, subdag, session=NEW_SESSION, conf=None, propagate_skipped_state=None, **kwargs)[source]

Bases: airflow.sensors.base.BaseSensorOperator

This class is deprecated, please use airflow.utils.task_group.TaskGroup.

This runs a sub dag. By convention, a sub dag’s dag_id should be prefixed by its parent and a dot. As in parent.child. Although SubDagOperator can occupy a pool/concurrency slot, user can specify the mode=reschedule so that the slot will be released periodically to avoid potential deadlock.

Parameters
ui_color = '#555'[source]
ui_fgcolor = '#fff'[source]
subdag: airflow.models.dag.DAG[source]
pre_execute(context)[source]

Execute right before self.execute() is called.

poke(context)[source]

Override when deriving this class.

post_execute(context, result=None)[source]

Execute right after self.execute() is called.

It is passed the execution context and any results returned by the operator.

Was this entry helpful?