VN
Очень интересно)
Size: a a a
2020 November 16
ME
А, нет, обманул. Даг не обновился, сейчас снова висит (раскомментил строку с end_date)
висит без единого запуска или отработал 1 раз?
VN
Ни разу, висит
VN
Статуса у таска нет вообще
GB
А default_args как передаёшь?
Может странный вопрос, но выглядит будто в таски в op_kwargs какой-то, а не в ДАГ
Может странный вопрос, но выглядит будто в таски в op_kwargs какой-то, а не в ДАГ
VN
dag = DAG(
....
default_args=default_args,
....
)
....
default_args=default_args,
....
)
GB
Ну мало ли)
GB
А если через cli или trigger DAG запустить?
GB
Ну и говорит ли что-то шедулер, кстати, в его логах обычно важное
VN
Не выйдет. Нас в этом ограничили конкретно. Из терминала не работает airflow.
GB
Какой экзекьютор? Может ли быть такое, что на очередь таска никто не подписан?
GB
Хотя тут бы end_date не влияла)
ME
Не выйдет. Нас в этом ограничили конкретно. Из терминала не работает airflow.
черезе UI триггернуть даг просто
ME
заработает или нет
ME
VN
Экзекьютор Celery, база постгре. Другие даги работают хорошо, до тех пор пока end_date не указать
GB
А версия какая? Может баг был какой, и имеет смысл обновиться до 12
VN
ну после этого он и висит
VN
Версия не свежая - 1.10.7
ME
Тогда только логи читать, что там такое случилось...