airflow (1) 썸네일형 리스트형 [airflow] argument 전달 1. 직접 trigger할때 dag_run 입력 airflow ui를 통해서 인자를 전달할 수 있다. json 으로 입력해야 하며, opreator에 provide_context=True로 옵션을 주면 함수에 전달된다. def print_test0(**context): dag_run: DagRun = context['dag_run'] print(dag_run.conf[name]) t0 = PythonOperator( task_id='print_test0', python_callable=print_test0, execution_timeout=timedelta(minutes=2), provide_context=True, dag=dag ) 2. default 값 입력 def print_test1(*op_arg.. 이전 1 다음
