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

Reduce to 25 dags

parent 9b1c382c
......@@ -5,7 +5,7 @@ from airflow.operators.bash_operator import BashOperator
with DAG(
dag_id="test_dag", start_date=datetime(2021, 10, 1), schedule_interval="@daily"
dag_id="test_dag", start_date=datetime(2021, 11, 1), schedule_interval="@daily"
) as dag:
BashOperator(
task_id="bash_task_test_dag",
......
......@@ -5,7 +5,7 @@ from airflow.operators.bash_operator import BashOperator
with DAG(
dag_id="test_dag_1", start_date=datetime(2021, 10, 1), schedule_interval="@daily"
dag_id="test_dag_1", start_date=datetime(2021, 11, 1), schedule_interval="@daily"
) as dag:
BashOperator(
task_id="bash_task_test_dag_1",
......
......@@ -5,7 +5,7 @@ from airflow.operators.bash_operator import BashOperator
with DAG(
dag_id="test_dag_10", start_date=datetime(2021, 10, 1), schedule_interval="@daily"
dag_id="test_dag_10", start_date=datetime(2021, 11, 1), schedule_interval="@daily"
) as dag:
BashOperator(
task_id="bash_task_test_dag_10",
......
......@@ -5,7 +5,7 @@ from airflow.operators.bash_operator import BashOperator
with DAG(
dag_id="test_dag_11", start_date=datetime(2021, 10, 1), schedule_interval="@daily"
dag_id="test_dag_11", start_date=datetime(2021, 11, 1), schedule_interval="@daily"
) as dag:
BashOperator(
task_id="bash_task_test_dag_11",
......
......@@ -5,7 +5,7 @@ from airflow.operators.bash_operator import BashOperator
with DAG(
dag_id="test_dag_12", start_date=datetime(2021, 10, 1), schedule_interval="@daily"
dag_id="test_dag_12", start_date=datetime(2021, 11, 1), schedule_interval="@daily"
) as dag:
BashOperator(
task_id="bash_task_test_dag_12",
......
......@@ -5,7 +5,7 @@ from airflow.operators.bash_operator import BashOperator
with DAG(
dag_id="test_dag_13", start_date=datetime(2021, 10, 1), schedule_interval="@daily"
dag_id="test_dag_13", start_date=datetime(2021, 11, 1), schedule_interval="@daily"
) as dag:
BashOperator(
task_id="bash_task_test_dag_13",
......
......@@ -5,7 +5,7 @@ from airflow.operators.bash_operator import BashOperator
with DAG(
dag_id="test_dag_14", start_date=datetime(2021, 10, 1), schedule_interval="@daily"
dag_id="test_dag_14", start_date=datetime(2021, 11, 1), schedule_interval="@daily"
) as dag:
BashOperator(
task_id="bash_task_test_dag_14",
......
......@@ -5,7 +5,7 @@ from airflow.operators.bash_operator import BashOperator
with DAG(
dag_id="test_dag_15", start_date=datetime(2021, 10, 1), schedule_interval="@daily"
dag_id="test_dag_15", start_date=datetime(2021, 11, 1), schedule_interval="@daily"
) as dag:
BashOperator(
task_id="bash_task_test_dag_15",
......
......@@ -5,7 +5,7 @@ from airflow.operators.bash_operator import BashOperator
with DAG(
dag_id="test_dag_16", start_date=datetime(2021, 10, 1), schedule_interval="@daily"
dag_id="test_dag_16", start_date=datetime(2021, 11, 1), schedule_interval="@daily"
) as dag:
BashOperator(
task_id="bash_task_test_dag_16",
......
......@@ -5,7 +5,7 @@ from airflow.operators.bash_operator import BashOperator
with DAG(
dag_id="test_dag_17", start_date=datetime(2021, 10, 1), schedule_interval="@daily"
dag_id="test_dag_17", start_date=datetime(2021, 11, 1), schedule_interval="@daily"
) as dag:
BashOperator(
task_id="bash_task_test_dag_17",
......
......@@ -5,7 +5,7 @@ from airflow.operators.bash_operator import BashOperator
with DAG(
dag_id="test_dag_18", start_date=datetime(2021, 10, 1), schedule_interval="@daily"
dag_id="test_dag_18", start_date=datetime(2021, 11, 1), schedule_interval="@daily"
) as dag:
BashOperator(
task_id="bash_task_test_dag_18",
......
......@@ -5,7 +5,7 @@ from airflow.operators.bash_operator import BashOperator
with DAG(
dag_id="test_dag_19", start_date=datetime(2021, 10, 1), schedule_interval="@daily"
dag_id="test_dag_19", start_date=datetime(2021, 11, 1), schedule_interval="@daily"
) as dag:
BashOperator(
task_id="bash_task_test_dag_19",
......
......@@ -5,7 +5,7 @@ from airflow.operators.bash_operator import BashOperator
with DAG(
dag_id="test_dag_2", start_date=datetime(2021, 10, 1), schedule_interval="@daily"
dag_id="test_dag_2", start_date=datetime(2021, 11, 1), schedule_interval="@daily"
) as dag:
BashOperator(
task_id="bash_task_test_dag_2",
......
......@@ -5,7 +5,7 @@ from airflow.operators.bash_operator import BashOperator
with DAG(
dag_id="test_dag_20", start_date=datetime(2021, 10, 1), schedule_interval="@daily"
dag_id="test_dag_20", start_date=datetime(2021, 11, 1), schedule_interval="@daily"
) as dag:
BashOperator(
task_id="bash_task_test_dag_20",
......
......@@ -5,7 +5,7 @@ from airflow.operators.bash_operator import BashOperator
with DAG(
dag_id="test_dag_21", start_date=datetime(2021, 10, 1), schedule_interval="@daily"
dag_id="test_dag_21", start_date=datetime(2021, 11, 1), schedule_interval="@daily"
) as dag:
BashOperator(
task_id="bash_task_test_dag_21",
......
......@@ -5,7 +5,7 @@ from airflow.operators.bash_operator import BashOperator
with DAG(
dag_id="test_dag_22", start_date=datetime(2021, 10, 1), schedule_interval="@daily"
dag_id="test_dag_22", start_date=datetime(2021, 11, 1), schedule_interval="@daily"
) as dag:
BashOperator(
task_id="bash_task_test_dag_22",
......
......@@ -5,7 +5,7 @@ from airflow.operators.bash_operator import BashOperator
with DAG(
dag_id="test_dag_23", start_date=datetime(2021, 10, 1), schedule_interval="@daily"
dag_id="test_dag_23", start_date=datetime(2021, 11, 1), schedule_interval="@daily"
) as dag:
BashOperator(
task_id="bash_task_test_dag_23",
......
......@@ -5,7 +5,7 @@ from airflow.operators.bash_operator import BashOperator
with DAG(
dag_id="test_dag_24", start_date=datetime(2021, 10, 1), schedule_interval="@daily"
dag_id="test_dag_24", start_date=datetime(2021, 11, 1), schedule_interval="@daily"
) as dag:
BashOperator(
task_id="bash_task_test_dag_24",
......
......@@ -5,7 +5,7 @@ from airflow.operators.bash_operator import BashOperator
with DAG(
dag_id="test_dag_25", start_date=datetime(2021, 10, 1), schedule_interval="@daily"
dag_id="test_dag_25", start_date=datetime(2021, 11, 1), schedule_interval="@daily"
) as dag:
BashOperator(
task_id="bash_task_test_dag_25",
......
from datetime import datetime
from airflow import DAG
from airflow.operators.bash_operator import BashOperator
with DAG(
dag_id="test_dag_26", start_date=datetime(2021, 10, 1), schedule_interval="@daily"
) as dag:
BashOperator(
task_id="bash_task_test_dag_26",
bash_command="echo hello world",
)
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