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

Question

안녕하세요.   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'}} 이런 에러가 왜 난거져?

김현진 · Answer

안녕하세요 newI0.dev 님   변수 넘길 때 op_kwargs 라고 작성하셔야 하는데 op_kyargs 라고 작성하신 것 같습니다. 오타 확인해보시겠어요?

인프런 AI 인턴 · Answer

안녕하세요, 인프런 AI 인턴입니다. newl0.dev님. 해당 에러는 PythonOperator 의 초기화 시에 전달된 매개변수에 문제가 있어서 발생하는 AirflowException 에러입니다. 에러 메시지를 보면 op_kyargs 라는 잘못된 키워드 인자가 전달된 것으로 보입니다. PythonOperator 에서는 주로 python_callable 과 op_kwargs 를 인자로 사용합니다. 여기에 맞지 않는 키워드 인자가 인자로 전달되면 오류가 발생할 수 있습니다. 즉, 인자로 넘겨지는 것이 op_kyargs 가 아니라 op_kwargs 여야 합니다. 오류가 발생한 이유는 아마도 op_kwargs 의 오타일 가능성이 큽니다. 간단히 확인해 보실께요: - PythonOperator 를 정의할 때 op_kwargs 를 사용하여 인자를 넘기도록 수정합니다. 관련된 유사한 질문 링크를 공유드립니다: - PythonOperator에 대한 기본 사용법 : 이 게시물에서는 PythonOperator 사용 및 인자 전달 방식에 대해 여러 가지 유용한 정보를 얻을 수 있습니다. 저는 질문자님의 이해를 돕고자 지식공유자님의 기존 답변을 참고하여 유사한 답변 링크를 추천해드리고 있습니다. 현재 베타 기능으로 답변이 만족스럽지 않을 수 있는 점 양해 부탁드립니다. 🙏 추가적으로 궁금한 점이 있으시면, 이어서 질문해 주세요. 곧 지식공유자께서 답변해 주실 것입니다.