Запуск DAG внутри контейнера воздушного потока работает нормально, но при запуске из Интернета выдает исключение AirflowException («Ошибка команды Bash») - PullRequest
0 голосов
/ 16 октября 2019

Если я запускаю группу обеспечения доступности баз данных в контейнере 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, но он также не работал.

...