Как предотвратить поток воздуха от засыпки?

Скажем, у вас есть DAG с воздушным потоком, который не имеет смысла для обратной засыпки, а это означает, что после однократного запуска его в последующие периоды будет совершенно бессмысленным.

Например, если вы загружаете данные из какого-либо источника, который обновляется ежечасно, в вашу базу данных, обратная засыпка, которая происходит в быстрой последовательности, будет просто импортировать одни и те же данные снова и снова.

Это особенно раздражает, когда вы создаете новую почасовую задачу, и она запускаетсяN количество раз за каждый пропущенный час, выполняющий избыточную работу, прежде чем он начнет работать с указанным интервалом.

Единственное решение, которое я могу придумать, - это то, против чего они специально рекомендовалиFAQ по документам

Мы не рекомендуем использовать динамические значения в качестве start_date, особенноdatetime.now() как это может быть довольно запутанным.

Есть ли способ отключить обратную засыпку для DAG, или я должен сделать выше?

Ответы на вопрос(3)

Ваш ответ на вопрос