This module is deprecated. Please use
The module which provides a way to nest your DAGs and so your levels of complexity.
Available options for skipped state propagation of subdag's tasks to parent dag tasks.
This class is deprecated.
- class airflow.operators.subdag.SkippedStatePropagationOptions¶
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)¶
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.
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 (Optional[Dict]) – Configuration for the subdag
propagate_skipped_state (Optional[SkippedStatePropagationOptions]) – 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(self, context)¶
This hook is triggered right before self.execute() is called.
- poke(self, context)¶
Function that the sensors defined while deriving this class should override.
- post_execute(self, context, result=None)¶
This hook is triggered right after self.execute() is called. It is passed the execution context and any results returned by the operator.