Если я запускаю группу обеспечения доступности баз данных в контейнере Docker с помощью команды airflow run dag_A task_1 ...
, она работает нормально. Но если я вызову ту же группу доступности базы данных через веб-интерфейс, произойдет сбой со следующей ошибкой: AirflowException: Bash command failed
. Просматривая журналы ошибок, обнаружил эту ошибку ImportError: No module named some-lib
, где some-lib
- локальный модуль внутри папки dag. Я думаю, что ошибка связана с этим вопросом, опубликованным в SO - Apache Airflow DAG не может импортировать локальный модуль
Я добавил файлы __init__.py
в папку и подпапки dag, но не сделалкажется, чтобы помочь. Я также установил ENV PYTHONPATH=<path-to-dag>:${PYTHONPATH}
в Dockerfile, но он также не работал.