Broken DAG: [ссылка] не может импортировать имя 'FileSensor'

Question

Я получаю эту ошибку в интерфейсе воздушного потока. введенная строка кода: из airflow.contrib.sensors.file_sensor import FileSensor есть идеи? ничего не нашел в гугле.

спасибо

Answer 1

Используете ли вы версию Airflow <1.10, например, 1.9? В этом случае попробуйте следующее: </p>

from airflow.contrib.operators.fs_operator import FileSensor

Я пробовал это в v1.10.9, и следующие обе работы.

from airflow.contrib.sensors.file_sensor import FileSensor
from airflow.contrib.operators.fs_operator import FileSensor

См. Следующие ссылки для справки:

https://github.com/apache/airflow/blob/v1-9-stable/airflow/contrib/operators/fs_operator.py https://github.com/apache/airflow/blob/v1-9-stable/airflow/contrib/operators/ init .py