Helper function to generate a DAG and operators given some arguments.
Module Contents
Functions
subdag(parent_dag_name, child_dag_name, args)
|
Generate a DAG to be used as a subdag. |
-
airflow.example_dags.subdags.subdag.subdag(parent_dag_name, child_dag_name, args)[source]
Generate a DAG to be used as a subdag.
- Parameters
parent_dag_name (str) – Id of the parent DAG
child_dag_name (str) – Id of the child DAG
args (dict) – Default arguments to provide to the subdag
- Returns
DAG to use as a subdag
- Return type
airflow.models.dag.DAG