Dag 에러가 나는데 모르겠어요

Airflow 마스터 클래스

Python 오퍼레이터에 op_kwargs로 변수 할당하기

작성

안녕하세요.

Broken DAG: [/opt/airflow/dags/dags_python_with_op_kyargs.py] Traceback (most recent call last): File "/home/airflow/.local/lib/python3.12/site-packages/airflow/models/baseoperator.py", line 508, in apply_defaults result = func(self, kwargs, default_args=default_args) ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ File "/home/airflow/.local/lib/python3.12/site-packages/airflow/models/baseoperator.py", line 959, in init raise AirflowException( airflow.exceptions.AirflowException: Invalid arguments were passed to PythonOperator (task_id: regist2_t1). Invalid arguments were: kwargs: {'op_kyargs': {'email': '@naver.com', 'phone': '010'}}

이런 에러가 왜 난거져?

python 데이터-엔지니어링 airflow

답변 2

김현진

지식공유자

안녕하세요 newI0.dev 님

변수 넘길 때 op_kwargs 라고 작성하셔야 하는데 op_kyargs 라고 작성하신 것 같습니다.

오타 확인해보시겠어요?

인프런 AI 인턴

안녕하세요, 인프런 AI 인턴입니다. newl0.dev님.

해당 에러는 PythonOperator의 초기화 시에 전달된 매개변수에 문제가 있어서 발생하는 AirflowException 에러입니다. 에러 메시지를 보면 op_kyargs라는 잘못된 키워드 인자가 전달된 것으로 보입니다.

PythonOperator에서는 주로 python_callable과 op_kwargs를 인자로 사용합니다. 여기에 맞지 않는 키워드 인자가 인자로 전달되면 오류가 발생할 수 있습니다. 즉, 인자로 넘겨지는 것이 op_kyargs가 아니라 op_kwargs여야 합니다. 오류가 발생한 이유는 아마도 op_kwargs의 오타일 가능성이 큽니다.

간단히 확인해 보실께요:
- PythonOperator를 정의할 때 op_kwargs를 사용하여 인자를 넘기도록 수정합니다.

관련된 유사한 질문 링크를 공유드립니다:
- PythonOperator에 대한 기본 사용법: 이 게시물에서는 PythonOperator 사용 및 인자 전달 방식에 대해 여러 가지 유용한 정보를 얻을 수 있습니다.

저는 질문자님의 이해를 돕고자 지식공유자님의 기존 답변을 참고하여 유사한 답변 링크를 추천해드리고 있습니다. 현재 베타 기능으로 답변이 만족스럽지 않을 수 있는 점 양해 부탁드립니다. 🙏 추가적으로 궁금한 점이 있으시면, 이어서 질문해 주세요. 곧 지식공유자께서 답변해 주실 것입니다.

인프런 커뮤니티 질문&답변

Dag 에러가 나는데 모르겠어요