при попытке запуска dag и Airflow возвращается код состояния2

Question

Эй, я действительно изо всех сил здесь с воздушным потоком на этом.У меня есть два других дагов, не вызывающих проблем, однако по некоторым причинам эти дагы терпят неудачу, и я не получаю много возврата, которая имеет смысл для меня в журналах.Я могу выполнить эту задачу без проблем как пользователь воздушного потока через командную строку, но по какой-то причине, когда я пытаюсь сделать это через dag, я получаю код выхода 2. Есть ли у кого-нибудь какие-нибудь указатели на это?Спасибо

[2018-09-18 20: 08: 18,886] {base_task_runner.py:95} INFO - подзадача: поток воздуха: ошибка: нераспознанные аргументы: запустите pull_dcm_today_data pull_dcm_today_data 2018-09-18T19:00:00 --job_id 8 --raw -sd DAGS_FOLDER / run_pull_dcm_today.py

[2018-09-18 20: 08: 22,579] {jobs.py:2083} INFO - задача завершена с кодом возврата 2

Answer 1

Попробуйте протестировать каждую из задач по порядку, используя команду airflow test.Если все задачи выполняются успешно, но группа обеспечения доступности баз продолжает работать, вам, вероятно, потребуется перезапустить весь проект (веб-сервер, планировщик и рабочие), потому что вы могли где-то устаревший код.