我尝试在我的dag中使用PythonSensor，但无法导入它。
from airflow.sensors.python_sensor import PythonSensor
wait_for_stg_completion = PythonSensor(
task_id='wait_for_stg_completion',
python_callable=fetch_stg_qa_status
)我如何导入它？我还可以尝试什么？
我尝试在我的dag中使用PythonSensor，但无法导入它。
from airflow.sensors.python_sensor import PythonSensor
wait_for_stg_completion = PythonSensor(
task_id='wait_for_stg_completion',
python_callable=fetch_stg_qa_status
)我如何导入它？我还可以尝试什么？
2条答案
按热度按时间vh0rcniy1#
对于气流〈2.0.0：
在这方面，
PythonSensor是独一无二的。人们会期望像其他核心传感器一样在airflow.sensors中找到它，但事实并非如此。对于气流〉= 2.0.0：
您也可以从
contrib导入，但它会显示弃用警告，因此最好使用更新后的路径。k97glaaz2#
导入不正确。请使用
from airflow.sensors.python import PythonSensor