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

Question

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

У меня есть два варианта:
1. Разрешите запускать только один экземпляр DAG одновременно и чаще запускайте DAG
2. Имейте другой DAG, чтобы посмотреть и начать, когда это необходимо.

Кто-нибудь реализовал это? Предложения? Спасибо!

Answer 1

Запланируйте непрерывный запуск DAG с воздушным потоком

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

Answer 2

Зачем вам нужен поток воздуха для этого? Вы могли бы реализовать бесконечный цикл в вашей искровой работе. Это кажется более эффективным.