Size: a a a

2021 March 08

AA

Anton Afonin in Airflow
Max Efremov
Скорее он просто ждал тот пул)
+
источник

JF

Justice For All in Airflow
Anton Afonin
Это про ручные запуски отдельных тасков, дело не в этом)
Но таск не был выполнен, он висел в состоянии "зашедулено". Все равно, даже такие таски отдельно не выполнить? (кроме как на селери или кубе)
источник

ME

Max Efremov in Airflow
Justice For All
Но таск не был выполнен, он висел в состоянии "зашедулено". Все равно, даже такие таски отдельно не выполнить? (кроме как на селери или кубе)
Нужно через clear их пускать
источник

AA

Anton Afonin in Airflow
Justice For All
Но таск не был выполнен, он висел в состоянии "зашедулено". Все равно, даже такие таски отдельно не выполнить? (кроме как на селери или кубе)
Он пытался получить свободное место в пуле, но его не было, он ждал, пока место освободиться)
источник

JF

Justice For All in Airflow
Max Efremov
Скорее он просто ждал тот пул)
Какой он терпеливый)) А нет сообщить, что так мол и так, пула то нет такого!
источник

ME

Max Efremov in Airflow
Он очистит текущий статус и запустит заново
источник

AA

Anton Afonin in Airflow
Кстати, в параметрах ждущего таска ничего не было полезного?
источник

JF

Justice For All in Airflow
Anton Afonin
Кстати, в параметрах ждущего таска ничего не было полезного?
например? таск_айди было, неправильный пул был, команда была
источник

AA

Anton Afonin in Airflow
ща скриншот сделаю найду
источник

JF

Justice For All in Airflow
Max Efremov
Он очистит текущий статус и запустит заново
Кстати, если шедулинг=Ноне, то аирфлоу сам саобой даг не запустит ни при каких обстоятельствах? Мне надо чтоб только в ручную
источник

AA

Anton Afonin in Airflow
источник

AA

Anton Afonin in Airflow
task details
источник

AA

Anton Afonin in Airflow
Там иногда полезно написано, почему не запускается
источник

JF

Justice For All in Airflow
Anton Afonin
Там иногда полезно написано, почему не запускается
спс
источник

AA

Anton Afonin in Airflow
источник

JF

Justice For All in Airflow
Anton Afonin
Там иногда полезно написано, почему не запускается
Да, действительно. Специально сломал всё обратно. В деталях есть "("Tasks using non-existent pool '%s' will not be scheduled", 'pool11')"
источник

AA

Anton Afonin in Airflow
Прекрасно) осталось ещё, чтобы он на главной странице это писал как ошибку)
источник

JF

Justice For All in Airflow
Anton Afonin
Прекрасно) осталось ещё, чтобы он на главной странице это писал как ошибку)
А какова дальнейшая судьба такого "сломанного" запуска? Вот я исправил код дага (поставил правильный пул). Насколько я понимаю - текущий ран этого дага все равно уже никогда не завершится, ибо ждет несуществующего пула. Что с таким раном делать? Их просто удаляют? Или помечать принудительно как 'failed'?
источник

JF

Justice For All in Airflow
Задача - остановить его, чтоб он уже больше ничего не ждал и завершился
источник

AA

Anton Afonin in Airflow
Если остановить - руками failed, если перезапустить - clear, как писали выше
источник