airflow.operators.subdag_operator

Module Contents

class airflow.operators.subdag_operator.SubDagOperator(subdag, executor=SequentialExecutor(), *args, **kwargs)

Bases: airflow.models.BaseOperator

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.

Parameters

• subdag (airflow.models.DAG) – the DAG object to run as a subdag of the current DAG.

• dag (airflow.models.DAG) – the parent DAG for the subdag.

• executor (airflow.executors.base_executor.BaseExecutor) – the executor for this subdag. Default to use SequentialExecutor. Please find AIRFLOW-74 for more details.

ui_color = #555

ui_fgcolor = #fff

execute(self, context)