Data/Data Engineering
2022. 3. 10.
[Airflow] 인자값 전송 및 Task raise exception
PythonOperator에서 함수값 넘겨주기 간략한 코드 예시 from airflow.operators.python import PythonOperator def temp_function(**context): print(context['params']['target_date'] # dict형식으로 왼쪽과 같은 방식으로 변수를 불러읽습니다 target_date = '2022-03-10' temp_function_job = PythonOperator( task_id='temp_function_job', python_callable=temp_function, params={ 'target_date': target_date, }, provide_context=True, dag=dag ) ############..
![[Airflow] 인자값 전송 및 Task raise exception](http://i1.daumcdn.net/thumb/C480x320/?fname=https://blog.kakaocdn.net/dn/cpsPAN/btrvE5DnosB/cCo1d8k3ODrk9O041KB4mK/img.png)