该异常通常是由于使用了错误的函数引用或未正确定义PythonOperator的python_callable
参数而引起的。为了解决此问题,需要确保以下几点:
python_callable
参数中定义的名称相同。例如:def my_function():
...
my_task = PythonOperator(task_id='my_task', python_callable=my_function)
def my_function(ds, **kwargs):
...
my_task = PythonOperator(task_id='my_task', python_callable=my_function, provide_context=True)
from my_module import my_function
my_task = PythonOperator(task_id='my_task', python_callable=my_function)
按照以上步骤进行操作后,应该可以成功执行PythonOperator并正确运行DAG。