<s> from datetime import datetime <EOL> from airflow . models import DAG <EOL> from airflow . operators import DummyOperator , SubDagOperator <EOL> from airflow . example_dags . subdags . subdag import subdag <EOL> DAG_NAME = '<STR_LIT>' <EOL> args = { <EOL> '<STR_LIT>' : '<STR_LIT>' , <EOL> '<STR_LIT>' : datetime ( <NUM_LIT> , <NUM_LIT:1> , <NUM_LIT:1> ) , <EOL> } <EOL> dag = DAG ( <EOL> dag_id = DAG_NAME , <EOL> default_args = args , <EOL> schedule_interval = "<STR_LIT>" , <EOL> ) <EOL> start = DummyOperator ( <EOL> task_id = '<STR_LIT:start>' , <EOL> default_args = args , <EOL> dag = dag , <EOL> ) <EOL> section_1 = SubDagOperator ( <EOL> task_id = '<STR_LIT>' , <EOL> subdag = subdag ( DAG_NAME , '<STR_LIT>' , args ) , <EOL> default_args = args , <EOL> dag = dag , <EOL> ) <EOL> some_other_task = DummyOperator ( <EOL> task_id = '<STR_LIT>' , <EOL> default_args = args , <EOL> dag = dag , <EOL> ) <EOL> section_2 = SubDagOperator ( <EOL> task_id = '<STR_LIT>' , <EOL> subdag = subdag ( DAG_NAME , '<STR_LIT>' , args ) , <EOL> default_args = args , <EOL> dag = dag , <EOL> ) <EOL> end = DummyOperator ( <EOL> task_id = '<STR_LIT:end>' , <EOL> default_args = args , <EOL> dag = dag , <EOL> ) <EOL> start . set_downstream ( section_1 ) <EOL> section_1 . set_downstream ( some_other_task ) <EOL> some_other_task . set_downstream ( section_2 ) <EOL> section_2 . set_downstream ( end ) </s>
