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?