36 lines
1.1 KiB
Python
36 lines
1.1 KiB
Python
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='gumanjomhaja',
|
|
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 |