Commit 59507a83 authored by Nicolas Paris's avatar Nicolas Paris
Browse files

Add 500 dags

parent c2ed59f8
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="echo hello world",
)
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="echo hello world",
)
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="echo hello world",
)
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="echo hello world",
)
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="echo hello world",
)
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="echo hello world",
)
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="echo hello world",
)
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="echo hello world",
)
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="echo hello world",
)
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="echo hello world",
)
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="echo hello world",
)
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="echo hello world",
)
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="echo hello world",
)
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="echo hello world",
)
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="echo hello world",
)
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="echo hello world",
)
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="echo hello world",
)
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="echo hello world",
)
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="echo hello world",
)
from datetime import datetime
from airflow import DAG
from airflow.operators.bash_operator import BashOperator
with DAG(
dag_id="test_dag_116", start_date=datetime(2019, 11, 28), schedule_interval="@daily"
) as dag:
BashOperator(
task_id="bash_task_test_dag_116",
bash_command="echo hello world",
)
Markdown is supported
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