AK
Кинешь страничку в доке?
Size: a a a
2020 October 06
ME
ME
или пайтон оператор с рандомной задержкой
ME
тоже вариант
2020 October 07
ДН
кто-нибудь заморачивался с wait_for_downstream на уровне дага?
нужно начинать выполнять таски следующего даграна, только после успешного завершения всего текущего даграна
нужно начинать выполнять таски следующего даграна, только после успешного завершения всего текущего даграна
С
кто-нибудь заморачивался с wait_for_downstream на уровне дага?
нужно начинать выполнять таски следующего даграна, только после успешного завершения всего текущего даграна
нужно начинать выполнять таски следующего даграна, только после успешного завершения всего текущего даграна
Max_active_runs =1?
NP
кто-нибудь заморачивался с wait_for_downstream на уровне дага?
нужно начинать выполнять таски следующего даграна, только после успешного завершения всего текущего даграна
нужно начинать выполнять таски следующего даграна, только после успешного завершения всего текущего даграна
Да
ДН
Сюткин
Max_active_runs =1?
я пока в голове не очень понимаю есть ли в этом проблема, но он начинает запуск следующего, если текущий фейлится
формально можно забить и не переподнимать, но теоретически можно попасть в ситуацию, когда 2ой таск 1ого даграна фейлится и ретраится в момент, когда работает 1ый таск другого даграна
формально можно забить и не переподнимать, но теоретически можно попасть в ситуацию, когда 2ой таск 1ого даграна фейлится и ретраится в момент, когда работает 1ый таск другого даграна
С
С
Судя по твоему заданию если упал даг ран следующий не должен стартануть,так?
ДН
Сюткин
Судя по твоему заданию если упал даг ран следующий не должен стартануть,так?
угу, потому что таски не самостоятельны сами по себе, самостоятелен только весь даг
depend_on_past (а точнее wait_for_downstream) не даст запустить упавшие таски в другом дагране, а выполненные - запустит
depend_on_past (а точнее wait_for_downstream) не даст запустить упавшие таски в другом дагране, а выполненные - запустит
С
В зависимости от триггер_rule очевидно?
С
Там же написано что триггер_руле стакается с depend_on_past
ДН
Да по-сути даже не важно какой сложности даг, хочется просто чтобы если текущий dagrun = failed, то следующий сидит ждет с самого начала
С
Depend_on_past =True
Trigger_rule = 'all_success'
Trigger_rule = 'all_success'
С
И впихнуть актив_ранс =1 наверно тоже не помешало бы
ДН
у меня wait_for_downstream стоит, он по умолчанию Depend_on_past =True врубает
Trigger_rule такой по-дефолту, я его нигде кастомный не ставил
max_active_runs = 1 стоит на уровне конфига
Trigger_rule такой по-дефолту, я его нигде кастомный не ставил
max_active_runs = 1 стоит на уровне конфига
ДН
но к сожалению это все решает проблему только на уровне task instance)
С
Ок,сча проверю у себя