Поток воздуха контролирует местоположение DAG для новых DAG и забирает их (каждую минуту или около того) без необходимости перезапуска.
Что произойдет, если обновленное определение dag будет загружено в местоположение dag?
Предположим, у меня есть тег с именем "foodag", который генерирует 1 файл и работает каждый час в час. Ровно в 01:00 я развернул новую версию «foodag», которая теперь генерирует 2 файла. В настоящее время выполняется запуск, начинающийся в 0100, а другой - в 0200.
Сколько файлов сгенерирует запуск в 0100? Есть ли здесь условия гонки? А как насчет 0200?