<s> from airflow . models import DAG <EOL> from airflow . operators import DummyOperator <EOL> def subdag ( parent_dag_name , child_dag_name , args ) : <EOL> dag_subdag = DAG ( <EOL> dag_id = '<STR_LIT>' % ( parent_dag_name , child_dag_name ) , <EOL> default_args = args , <EOL> schedule_interval = "<STR_LIT>" , <EOL> ) <EOL> for i in range ( <NUM_LIT:5> ) : <EOL> DummyOperator ( <EOL> task_id = '<STR_LIT>' % ( child_dag_name , i + <NUM_LIT:1> ) , <EOL> default_args = args , <EOL> dag = dag_subdag , <EOL> ) <EOL> return dag_subdag </s>
