Commit c2ed59f8 authored by Nicolas Paris's avatar Nicolas Paris
Browse files

Reduce number dags

parent 3a04a56b
......@@ -9,5 +9,5 @@ with DAG(
) as dag:
BashOperator(
task_id="bash_task_test_dag",
bash_command="touch /tmp/result_test_dag",
bash_command="echo hello world",
)
from datetime import datetime
from airflow import DAG
from airflow.operators.bash_operator import BashOperator
with DAG(
dag_id="test_dag_1", start_date=datetime(2019, 11, 28), schedule_interval="@daily"
) as dag:
BashOperator(
task_id="bash_task_test_dag_1",
bash_command="touch /tmp/result_test_dag_1",
)
from datetime import datetime
from airflow import DAG
from airflow.operators.bash_operator import BashOperator
with DAG(
dag_id="test_dag_10", start_date=datetime(2019, 11, 28), schedule_interval="@daily"
) as dag:
BashOperator(
task_id="bash_task_test_dag_10",
bash_command="touch /tmp/result_test_dag_10",
)
from datetime import datetime
from airflow import DAG
from airflow.operators.bash_operator import BashOperator
with DAG(
dag_id="test_dag_100", start_date=datetime(2019, 11, 28), schedule_interval="@daily"
) as dag:
BashOperator(
task_id="bash_task_test_dag_100",
bash_command="touch /tmp/result_test_dag_100",
)
from datetime import datetime
from airflow import DAG
from airflow.operators.bash_operator import BashOperator
with DAG(
dag_id="test_dag_101", start_date=datetime(2019, 11, 28), schedule_interval="@daily"
) as dag:
BashOperator(
task_id="bash_task_test_dag_101",
bash_command="touch /tmp/result_test_dag_101",
)
from datetime import datetime
from airflow import DAG
from airflow.operators.bash_operator import BashOperator
with DAG(
dag_id="test_dag_102", start_date=datetime(2019, 11, 28), schedule_interval="@daily"
) as dag:
BashOperator(
task_id="bash_task_test_dag_102",
bash_command="touch /tmp/result_test_dag_102",
)
from datetime import datetime
from airflow import DAG
from airflow.operators.bash_operator import BashOperator
with DAG(
dag_id="test_dag_103", start_date=datetime(2019, 11, 28), schedule_interval="@daily"
) as dag:
BashOperator(
task_id="bash_task_test_dag_103",
bash_command="touch /tmp/result_test_dag_103",
)
from datetime import datetime
from airflow import DAG
from airflow.operators.bash_operator import BashOperator
with DAG(
dag_id="test_dag_104", start_date=datetime(2019, 11, 28), schedule_interval="@daily"
) as dag:
BashOperator(
task_id="bash_task_test_dag_104",
bash_command="touch /tmp/result_test_dag_104",
)
from datetime import datetime
from airflow import DAG
from airflow.operators.bash_operator import BashOperator
with DAG(
dag_id="test_dag_105", start_date=datetime(2019, 11, 28), schedule_interval="@daily"
) as dag:
BashOperator(
task_id="bash_task_test_dag_105",
bash_command="touch /tmp/result_test_dag_105",
)
from datetime import datetime
from airflow import DAG
from airflow.operators.bash_operator import BashOperator
with DAG(
dag_id="test_dag_106", start_date=datetime(2019, 11, 28), schedule_interval="@daily"
) as dag:
BashOperator(
task_id="bash_task_test_dag_106",
bash_command="touch /tmp/result_test_dag_106",
)
from datetime import datetime
from airflow import DAG
from airflow.operators.bash_operator import BashOperator
with DAG(
dag_id="test_dag_107", start_date=datetime(2019, 11, 28), schedule_interval="@daily"
) as dag:
BashOperator(
task_id="bash_task_test_dag_107",
bash_command="touch /tmp/result_test_dag_107",
)
from datetime import datetime
from airflow import DAG
from airflow.operators.bash_operator import BashOperator
with DAG(
dag_id="test_dag_108", start_date=datetime(2019, 11, 28), schedule_interval="@daily"
) as dag:
BashOperator(
task_id="bash_task_test_dag_108",
bash_command="touch /tmp/result_test_dag_108",
)
from datetime import datetime
from airflow import DAG
from airflow.operators.bash_operator import BashOperator
with DAG(
dag_id="test_dag_109", start_date=datetime(2019, 11, 28), schedule_interval="@daily"
) as dag:
BashOperator(
task_id="bash_task_test_dag_109",
bash_command="touch /tmp/result_test_dag_109",
)
from datetime import datetime
from airflow import DAG
from airflow.operators.bash_operator import BashOperator
with DAG(
dag_id="test_dag_11", start_date=datetime(2019, 11, 28), schedule_interval="@daily"
) as dag:
BashOperator(
task_id="bash_task_test_dag_11",
bash_command="touch /tmp/result_test_dag_11",
)
from datetime import datetime
from airflow import DAG
from airflow.operators.bash_operator import BashOperator
with DAG(
dag_id="test_dag_110", start_date=datetime(2019, 11, 28), schedule_interval="@daily"
) as dag:
BashOperator(
task_id="bash_task_test_dag_110",
bash_command="touch /tmp/result_test_dag_110",
)
from datetime import datetime
from airflow import DAG
from airflow.operators.bash_operator import BashOperator
with DAG(
dag_id="test_dag_111", start_date=datetime(2019, 11, 28), schedule_interval="@daily"
) as dag:
BashOperator(
task_id="bash_task_test_dag_111",
bash_command="touch /tmp/result_test_dag_111",
)
from datetime import datetime
from airflow import DAG
from airflow.operators.bash_operator import BashOperator
with DAG(
dag_id="test_dag_112", start_date=datetime(2019, 11, 28), schedule_interval="@daily"
) as dag:
BashOperator(
task_id="bash_task_test_dag_112",
bash_command="touch /tmp/result_test_dag_112",
)
from datetime import datetime
from airflow import DAG
from airflow.operators.bash_operator import BashOperator
with DAG(
dag_id="test_dag_113", start_date=datetime(2019, 11, 28), schedule_interval="@daily"
) as dag:
BashOperator(
task_id="bash_task_test_dag_113",
bash_command="touch /tmp/result_test_dag_113",
)
from datetime import datetime
from airflow import DAG
from airflow.operators.bash_operator import BashOperator
with DAG(
dag_id="test_dag_114", start_date=datetime(2019, 11, 28), schedule_interval="@daily"
) as dag:
BashOperator(
task_id="bash_task_test_dag_114",
bash_command="touch /tmp/result_test_dag_114",
)
from datetime import datetime
from airflow import DAG
from airflow.operators.bash_operator import BashOperator
with DAG(
dag_id="test_dag_115", start_date=datetime(2019, 11, 28), schedule_interval="@daily"
) as dag:
BashOperator(
task_id="bash_task_test_dag_115",
bash_command="touch /tmp/result_test_dag_115",
)
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment