Airflow
Op Kwargs
  • 함수가 일반 변수만 있을 경우
def regist(name, sex):
	print(f'이름은 {name}이고 성별은 {sex}입니다.)
python_task = PythonOperator(
	task_id = 'python_task',
	python_callable = regist,
	op_kwargs = {'name':'hojoon', 'sex' :'man'}
)
  • 함수에 일반 변수 + **kwargs도 있을 경우
def regist (name, sex, **kwargs):
	print(name)
	print(sex)
	print(kwargs)
python_task = PythonOperator(
	task_id = 'python_task',
	python_Callable =regist,
	op_kwargs = {'name':'hjkim',}
)

*args **kwargs

def regist (name, sex, *args, ***kwargs):
	print(name)
	print(sex)
	print(kwargs)