From b4b080d48cda5468517caa20cbb247f2b33d7f97 Mon Sep 17 00:00:00 2001
From: groupuser <groupuser@aifrica.co.kr>
Date: Wed, 24 Sep 2025 03:38:35 +0000
Subject: [PATCH] save.py committed by groupuser

---
 groupuser/save.py | 36 ++++++++++++++++++++++++++++++++++++
 1 file changed, 36 insertions(+)
 create mode 100644 groupuser/save.py

diff --git a/groupuser/save.py b/groupuser/save.py
new file mode 100644
index 0000000..b649926
--- /dev/null
+++ b/groupuser/save.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={DAG_ID_ENV},
+    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