airflow.example_dags.subdags.subdag

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.DAG

Was this entry helpful?