From a71660035964921896dae8e5f5ea17dbfd172340 Mon Sep 17 00:00:00 2001 From: Quang Trinh Date: Fri, 20 Sep 2024 10:05:46 +0700 Subject: [PATCH] Remove dags folder --- dags/demo_dag.py | 24 ------------------------ 1 file changed, 24 deletions(-) delete mode 100644 dags/demo_dag.py diff --git a/dags/demo_dag.py b/dags/demo_dag.py deleted file mode 100644 index c14bb09..0000000 --- a/dags/demo_dag.py +++ /dev/null @@ -1,24 +0,0 @@ -from airflow import DAG -from datetime import datetime, timedelta -from airflow.operators.bash import BashOperator - -start_date = datetime(2024, 9, 1) - -default_args = { - 'owner': 'airflow', - 'start_date': start_date, - 'retries': 1, - 'retry_delay': timedelta(seconds=5) -} - -with DAG('my_dag', default_args=default_args, schedule_interval='@daily', catchup=False) as dag: - t0 = BashOperator(task_id='ls_data', bash_command='echo "Listing data..."', retries=2, retry_delay=timedelta(seconds=15)) - - t1 = BashOperator(task_id='download_data', - bash_command='echo "Downloading data..."', - retries=2, retry_delay=timedelta(seconds=15)) - - t2 = BashOperator(task_id='check_file_exists', bash_command='echo "Checking data..."', - retries=2, retry_delay=timedelta(seconds=15)) - - t0 >> t1 >> t2 \ No newline at end of file