друзья, как вы решаете такой кейс
1) есть старый DAG с 3 операторами, работает продолжительное время, запускается каждый час
2) добавляем в него еще один оператор и хотим сделать backfill - выполнить исторические запуски для нового оператора, чтобы на пару месяцев назад просчитать необходимые данные (задачи довольно тяжелые, пересчет истории займет несколько дней)
3) как запустить пересчет назад так, чтобы он не блокировал выполнение новых ежечасных задач для старых операторов? понизить приоритет? пересчитывать порциями? если порциями, то как их автоматически задавать? (можно написать кастомный шелл-скрипт периодически перезапускающий старые экземпляры дагов через cli, но хочется более универсальное решение)