Summary

PythonOperator의 op_args는 list로 작성한다.

op_kwargs는 dictionary로 작성한다.

op_args 파라미터

# 일반 변수
python_task = PythonOperator(
    task_id='python_task',
    python_callable=regist,
    op_args=['hyun', 'male']
)
 
# 일반 변수 + *args
python_task = PythonOperator(
    task_id='python_task',
    python_callable=regist,
    op_args=['hyun', 'male', 'kr', 'seoul']  # 추가분은 args로 캡쳐
)

op_kwargs 파라미터

# 일반 변수
python_task = PythonOperator(
    task_id='python_task',
    python_callable=regist,
    op_kwargs={'name': 'hyun', 'sex': 'male'}
)
 
# 일반 변수 + **kwargs
python_task = PythonOperator(
    task_id='python_task',
    python_callable=regist,
    op_kwargs={'name': 'hyun', 'sex': 'male', 'country': 'kr', 'city': 'seoul'}
)

op_args + op_kwargs 함께 사용

python_task = PythonOperator(
    task_id='python_task',
    python_callable=regist,
    op_args=['hyun', 'male', 'kr', 'seoul'],
    op_kwargs={'phone': 010, 'mail': '[email protected]'}
)