这种问题通常是由于在Python Operator中传递了一个非可调用的函数作为python_callable参数导致的。可通过添加括号()
来调用函数来解决此问题。例如:
def my_function():
return "Hello, Airflow!"
my_operator = PythonOperator(
task_id="my_task",
python_callable=my_function # 未调用函数
)
# 可调用函数
my_operator = PythonOperator(
task_id="my_task",
python_callable=my_function() # 加了括号调用函数
)
上述示例中,第一个PythonOperator中的python_callable
参数没有调用函数,导致了AirflowException异常。而在第二个PythonOperator中,通过添加括号来调用函数,就解决了这个问题。