Телеграмм чат группы ruairflow страница 1735

дальше проверяйте слоты в пуле и настройку parallelism в airflow
если там все хорошо, но все равно не работает, то спускайтесь до специфики работы вашего экзекьютера

источник

11:38пожаловаться #12

Rustem in Airflow

Слоты в пуле это пойти а task instance detail и посмотреть атрибут pool_slots?

источник

12:17пожаловаться #13

Nikolai in Airflow

если пул не задавался, то скорее всего стоит дефолтный, идете в гуи админки в раздел пулов и смотрите, что у вас достаточно свободных слотов в default_pool

источник

12:18пожаловаться #14

Roman in Airflow

Всем привет
Тут такая ситуация: если даг факапится, то потом перестаёт запускать таски при сл запусках.
Как сделать так, что если он в 1 день сломался, на следующий все равно отработал?
(Последние запускались вручную)
Подскажите плиз

источник

12:22пожаловаться #15

Andrii Stasiuk in Airflow

Привет, а кто-то сталкивался с такой проблемой KeyError: 'Variable atlas_lineage_conf does not exist'? Я эту переменную не использую

источник

12:23пожаловаться #16

Igor in Airflow

А за таски другой параметр отвечает, dag_concurrency

У тебя там ещё где-то может быть какой-нибудь depends_on_past или wait_for_upstream, он тоже может влиять

источник

12:26пожаловаться #17

Igor in Airflow

Вот это как раз похоже на wait_for_upstream или depends_on_past

источник

12:26пожаловаться #18

Roman in Airflow

wait_for_upstream true
depends_on_past false

источник

12:29пожаловаться #19

Roman in Airflow

wait_for_upstream как-то аффектит на другие запуски? Я думал, это только в рамках дага

источник

12:31пожаловаться #20