From 28013d949fe7b175c2a7da82fdd5b5f94b16a437 Mon Sep 17 00:00:00 2001
From: cheetahadmin <cheetahadmin@aifrica.co.kr>
Date: Thu, 4 Sep 2025 03:55:07 +0000
Subject: [PATCH] Add dags/groupuser/cleanup_test

---
 dags/groupuser/cleanup_test | 36 ++++++++++++++++++++++++++++++++++++
 1 file changed, 36 insertions(+)
 create mode 100644 dags/groupuser/cleanup_test

diff --git a/dags/groupuser/cleanup_test b/dags/groupuser/cleanup_test
new file mode 100644
index 0000000..72f4eee
--- /dev/null
+++ b/dags/groupuser/cleanup_test
@@ -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='cleanup_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