Como impedir que o fluxo de ar encha corridas de dag?

Digamos que você tenha um DAG de fluxo de ar que não faz sentido preencher, o que significa que, depois de ser executado uma vez, executá-lo rapidamente nos momentos subsequentes seria completamente inútil.

Por exemplo, se você estiver carregando dados de alguma fonte que é atualizada apenas a cada hora no seu banco de dados, o preenchimento, que ocorre em rápida sucessão, apenas importaria os mesmos dados repetidamente.

Isso é especialmente irritante quando você instancia uma nova tarefa horária e é executadaN quantidade de vezes para cada hora que ele perdeu, realizando um trabalho redundante, antes de começar a executar no intervalo especificado.

A única solução em que consigo pensar é em algo que eles especificamente aconselharam emFAQ dos documentos

Recomendamos não usar valores dinâmicos como data_de_inicial, especialmentedatetime.now() como pode ser bastante confuso.

Existe alguma maneira de desativar o preenchimento de um DAG ou devo fazer o acima?

questionAnswers(3)

yourAnswerToTheQuestion