요약

PythonOperator의 op_args는 list로 작성

op_kwargs는 dictionary로 작성

1. 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로 캡쳐
)

2. 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'}
)

3. 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': 'hyun@naver.com'}
)

참고사이트