П
скиньте потом видео
Всем привет. Подскажите пожалуйста, нужно условие, выполнять экземпляр задачи, если экземпляр за предыдущий период выполнен успешно. Из описания параметров нашел что-то похожее
depends_on_past
wait_for_downstream
Size: a a a
2017 December 28
2017 December 29
OI
wait_for_downstream - это ожидание завершения предыдущих тасков в этом же даге (к которым выставлены зависимости).OI
здесь второй сенсор выполнится только после выполнения первого
OI
а вот
depends_on_past - это таск не запустится, пока успешно не отработает он же за предыдущий периодП
а вот
depends_on_past - это таск не запустится, пока успешно не отработает он же за предыдущий периодтогда это подходит, спасибо!
П
тут вопрос возникает, ведь по умолчанию trigger_rule стоит, что не выполнять, пока предыдущие таски не отработают, в чем разница тогда?
OI
если
wait_for_downstream выставить в False, то не будет таск не будет ожидать завершения предыдущих. Зачем это нужно, я не знаю)OI
Еще есть
ExternalTaskSensor. Его можно натравить не только на таск в другом даге, но и на разницу во времениOI
OI
Теоретически, наверное, можно даже на какой-нибудь таск из того же дага, где этот сенсор.
YE
Теоретически, наверное, можно даже на какой-нибудь таск из того же дага, где этот сенсор.
У нас так сделано. Контроль непересикаемости работы цепочек одного дага в разных датах.
П
Еще есть
ExternalTaskSensor. Его можно натравить не только на таск в другом даге, но и на разницу во времениdepends_on_past не подойдет, а вот ExternalTaskSensor думаю подойдет, попробую настроить на себя же, за предыдущую дату
П
Ребят, вне таска возможно получить дату исполения, для использования в другом месте?
П
динамическую генерацию тасков надо привязать к дате исполнения
OI
По-моему таски генерить внутри самого дага нельзя. Они генерятся в момент рендеринга, т.е. 1 раз, а потом выполняются.
OI
Или я как-то не так понял вопрос.
МС
По-моему таски генерить внутри самого дага нельзя. Они генерятся в момент рендеринга, т.е. 1 раз, а потом выполняются.
Ага. Тоже об это обожглись. Очень хотелось динамически генерить таски.
П
вопрос в том, что мне нужно получить дату исполнения
OI
ну это либо '{{ ds }}' там, где рендерится, либо kwargs["execution_date"] в каком-нибудь python operator