From 076d3c53f56eac07802536eb16c6fbc0990f181f Mon Sep 17 00:00:00 2001 From: cheetahadmin Date: Thu, 4 Sep 2025 05:16:16 +0000 Subject: [PATCH] Add dags/soosoo/entr_test.py --- dags/soosoo/entr_test.py | 36 ++++++++++++++++++++++++++++++++++++ 1 file changed, 36 insertions(+) create mode 100644 dags/soosoo/entr_test.py diff --git a/dags/soosoo/entr_test.py b/dags/soosoo/entr_test.py new file mode 100644 index 0000000..8768047 --- /dev/null +++ b/dags/soosoo/entr_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='entr_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