From 10bd565e5611d81c7d62bf9e8fbdda704ce62767 Mon Sep 17 00:00:00 2001 From: cheetahadmin Date: Wed, 3 Sep 2025 08:34:36 +0000 Subject: [PATCH] Add dags/soosoo/sidecar_test.py --- dags/soosoo/sidecar_test.py | 36 ++++++++++++++++++++++++++++++++++++ 1 file changed, 36 insertions(+) create mode 100644 dags/soosoo/sidecar_test.py diff --git a/dags/soosoo/sidecar_test.py b/dags/soosoo/sidecar_test.py new file mode 100644 index 0000000..167a799 --- /dev/null +++ b/dags/soosoo/sidecar_test.py @@ -0,0 +1,36 @@ +import time +import pendulum +from datetime import datetime +from airflow import DAG +from airflow.operators.python import PythonOperator + +KST = pendulum.timezone('Asia/Seoul') + +def task1(): + print('Task 1 execute time ', datetime.now(tz=KST).strftime('%Y-%m-%d %H-%M-%S')) + time.sleep(10) + +def task2(): + print('Task 2 execute time ', datetime.now(tz=KST).strftime('%Y-%m-%d %H-%M-%S')) + time.sleep(10) + +def task3(): + print('Task 3 execute time ', datetime.now(tz=KST).strftime('%Y-%m-%d %H-%M-%S')) + time.sleep(10) + +def task4(): + print('Task 4 execute time ', datetime.now(tz=KST).strftime('%Y-%m-%d %H-%M-%S')) + +with DAG( + dag_id='sidecar_test', + default_args={'retries': 1}, + schedule='@once', + start_date=datetime(2025, 8, 11, tzinfo=KST), + catchup=False, +) as dag: + t1 = PythonOperator(task_id='task1', python_callable=task1) + t2 = PythonOperator(task_id='task2', python_callable=task2) + t3 = PythonOperator(task_id='task3', python_callable=task3) + t4 = PythonOperator(task_id='task4', python_callable=task4) + + t1 >> t2 >> t3 >> t4 \ No newline at end of file