Как предотвратить поток воздуха от засыпки?
Скажем, у вас есть DAG с воздушным потоком, который не имеет смысла для обратной засыпки, а это означает, что после однократного запуска его в последующие периоды будет совершенно бессмысленным.
Например, если вы загружаете данные из какого-либо источника, который обновляется ежечасно, в вашу базу данных, обратная засыпка, которая происходит в быстрой последовательности, будет просто импортировать одни и те же данные снова и снова.
Это особенно раздражает, когда вы создаете новую почасовую задачу, и она запускаетсяN
количество раз за каждый пропущенный час, выполняющий избыточную работу, прежде чем он начнет работать с указанным интервалом.
Единственное решение, которое я могу придумать, - это то, против чего они специально рекомендовалиFAQ по документам
Мы не рекомендуем использовать динамические значения в качестве start_date, особенноdatetime.now()
как это может быть довольно запутанным.
Есть ли способ отключить обратную засыпку для DAG, или я должен сделать выше?