목록task decorator (1)

홍카나의 공부방

[Airflow] Task Decorator 간단 사용법

from airflow import DAG import pendulum from airflow.decorators import task with DAG( dag_id="example_python_operator", schedule="0 9 * * *", start_date=pendulum.datetime(2023, 11, 1, tz="Asia/Seoul"), catchup=False, tags=["example"], ) as dag: # [START howto_operator_python] @task(task_id="python_task_1") def print_context(some_input): print(some_input) python_task_1 = print_context("task decor..
Data Engineering/Airflow 2023. 11. 16. 14:40
이전 Prev 1 Next 다음