Запуск воздушного потока с указанием неверного -sd или -SUBDIRECTORY

У меня есть процесс Airflow, работающий каждый день со многими DAGS. Сегодня, внезапно, ни один из DAGS не может быть запущен, потому что когда Airflow вызывает airflow run он указывает каталог -sd, чтобы найти группу DAG.

Вот пример:

[2018-09-26 15:18:10,406] {base_task_runner.py:115} INFO - Running: ['bash', '-c', 'airflow run daily_execution dag1 2018-09-26T13:17:50.511269 --job_id 1 --raw -sd DAGS_FOLDER/newfoldernewfolder/dags/all_dags.py']

Как видите, сразу после -sd, подкаталог повторяет newfolder дважды, когда он должен только заявить DAGS_FOLDER/newfolder/dags/all_dags.py,

Я попытался запустить DAG с теми же файлами, которые были запущены два дня назад (когда все было правильно), но я получаю ту же ошибку. Я предполагаю, что что-то изменилось в конфигурации Airflow, но я не знаю никаких изменений в airflow.cfg, Я только управлял пользовательским интерфейсом и airflow run вызывается автоматически после включения DAG.

У кого-нибудь есть идея, где airflow run может получить этот каталог и как я могу обновить это?

0 ответов

Другие вопросы по тегам