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

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: DAG, session: Optional[Session] = None, conf: Optional[Dict] = None, propagate_skipped_state: Optional[SkippedStatePropagationOptions] = 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

  • subdag -- the DAG object to run as a subdag of the current DAG.

  • session -- sqlalchemy session

  • conf (dict) -- Configuration for the subdag

  • propagate_skipped_state -- by setting this argument you can define whether the skipped state of leaf task(s) should be propagated to the parent dag's downstream task.

ui_color = #555[source]
ui_fgcolor = #fff[source]
pre_execute(self, context)[source]
poke(self, context)[source]
post_execute(self, context, result=None)[source]

Was this entry helpful?