diff --git a/dags/soosoo/sync_test.py b/dags/soosoo/sync_test.py new file mode 100644 index 0000000..e836450 --- /dev/null +++ b/dags/soosoo/sync_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='DAG_sync_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