Воздушный поток - определите продолжительность, в течение которой DAG может работать

Question

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

Answer 1

DAG действительно имеют параметр dagrun_timeout, но он работает только при достижении max_active_runs для DAG (по умолчанию 16).Например, если у вас 15 активных групп доступности баз данных, планировщик просто запустит 16-е.Но перед запуском следующего планировщик будет ждать, пока один из предыдущих завершений или не превысит время ожидания.

Но вы можете использовать execution_timeout для экземпляра задачи.Этот параметр работает безоговорочно.