• Home
• airflow.operators.subdag

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

Bases: enum.Enum

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

ALL_LEAVES = 'all_leaves'

ANY_LEAF = 'any_leaf'

class airflow.operators.subdag.SubDagOperator(*, subdag, session=NEW_SESSION, conf=None, propagate_skipped_state=None, **kwargs)

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 (airflow.models.dag.DAG) – the DAG object to run as a subdag of the current DAG.

• session (sqlalchemy.orm.session.Session) – sqlalchemy session

• conf (dict | None) – Configuration for the subdag

• propagate_skipped_state (SkippedStatePropagationOptions | None) – 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'

ui_fgcolor = '#fff'

subdag: airflow.models.dag.DAG

pre_execute(context)

Execute right before self.execute() is called.

poke(context)

Override when deriving this class.

post_execute(context, result=None)

Execute right after self.execute() is called.

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

PreviousNext

Was this entry helpful?