<s> """<STR_LIT>""" <EOL> from datetime import datetime <EOL> from airflow . models import DAG <EOL> from airflow . operators import DummyOperator , PythonOperator , SubDagOperator <EOL> from airflow . utils . trigger_rule import TriggerRule <EOL> DEFAULT_DATE = datetime ( <NUM_LIT> , <NUM_LIT:1> , <NUM_LIT:1> ) <EOL> default_args = dict ( <EOL> start_date = DEFAULT_DATE , <EOL> owner = '<STR_LIT>' ) <EOL> def fail ( ) : <EOL> raise ValueError ( '<STR_LIT>' ) <EOL> dag1 = DAG ( dag_id = '<STR_LIT>' , default_args = default_args ) <EOL> dag1_task1 = DummyOperator ( <EOL> task_id = '<STR_LIT>' , <EOL> dag = dag1 , <EOL> pool = '<STR_LIT>' , ) <EOL> dag2 = DAG ( dag_id = '<STR_LIT>' , default_args = default_args ) <EOL> dag2_task1 = DummyOperator ( <EOL> task_id = '<STR_LIT>' , <EOL> dag = dag2 , <EOL> depends_on_past = True , ) <EOL> dag3 = DAG ( dag_id = '<STR_LIT>' , default_args = default_args ) <EOL> dag3_task1 = PythonOperator ( <EOL> task_id = '<STR_LIT>' , <EOL> dag = dag3 , <EOL> python_callable = fail ) <EOL> dag3_task2 = DummyOperator ( <EOL> task_id = '<STR_LIT>' , <EOL> dag = dag3 , ) <EOL> dag3_task2 . set_upstream ( dag3_task1 ) <EOL> dag4 = DAG ( dag_id = '<STR_LIT>' , default_args = default_args ) <EOL> dag4_task1 = PythonOperator ( <EOL> task_id = '<STR_LIT>' , <EOL> dag = dag4 , <EOL> python_callable = fail , <EOL> ) <EOL> dag4_task2 = DummyOperator ( <EOL> task_id = '<STR_LIT>' , <EOL> dag = dag4 , <EOL> trigger_rule = TriggerRule . ALL_FAILED <EOL> ) <EOL> dag4_task2 . set_upstream ( dag4_task1 ) <EOL> dag5 = DAG ( dag_id = '<STR_LIT>' , default_args = default_args ) <EOL> dag5_task1 = DummyOperator ( <EOL> task_id = '<STR_LIT>' , <EOL> dag = dag5 , <EOL> ) <EOL> dag5_task2 = PythonOperator ( <EOL> task_id = '<STR_LIT>' , <EOL> dag = dag5 , <EOL> python_callable = fail , <EOL> ) <EOL> dag6 = DAG ( dag_id = '<STR_LIT>' , default_args = default_args ) <EOL> dag6_task1 = DummyOperator ( <EOL> task_id = '<STR_LIT>' , <EOL> depends_on_past = True , <EOL> dag = dag6 , ) <EOL> dag6_task2 = DummyOperator ( <EOL> task_id = '<STR_LIT>' , <EOL> depends_on_past = True , <EOL> dag = dag6 , ) <EOL> dag6_task2 . set_upstream ( dag6_task1 ) <EOL> dag7 = DAG ( dag_id = '<STR_LIT>' , default_args = default_args ) <EOL> subdag7 = DAG ( dag_id = '<STR_LIT>' , default_args = default_args ) <EOL> subdag7_task1 = PythonOperator ( <EOL> task_id = '<STR_LIT>' , <EOL> dag = subdag7 , <EOL> python_callable = fail ) <EOL> subdag7_task2 = DummyOperator ( <EOL> task_id = '<STR_LIT>' , <EOL> dag = subdag7 , ) <EOL> subdag7_task3 = DummyOperator ( <EOL> task_id = '<STR_LIT>' , <EOL> dag = subdag7 ) <EOL> dag7_subdag1 = SubDagOperator ( <EOL> task_id = '<STR_LIT>' , <EOL> dag = dag7 , <EOL> subdag = subdag7 ) <EOL> subdag7_task1 . set_downstream ( subdag7_task2 ) <EOL> subdag7_task2 . set_downstream ( subdag7_task3 ) <EOL> dag8 = DAG ( <EOL> dag_id = '<STR_LIT>' , <EOL> start_date = DEFAULT_DATE , <EOL> end_date = DEFAULT_DATE , <EOL> default_args = default_args ) <EOL> dag8_task1 = PythonOperator ( <EOL> python_callable = fail , <EOL> task_id = '<STR_LIT>' , <EOL> dag = dag8 , <EOL> pool = '<STR_LIT>' ) </s>
