Режьте по доменам/стадиям (ingest/transform/publish), связывайте Datasets/TriggerDagRun, держите граф обозримым, выносите repeated patterns в библиотеки, не смешивайте несвязанные SLA.
Разбор
- Монолит тормозит parse и on-call понимание.
- Маленькие DAG проще ownership.
- Общий orchestrator DAG только для грубых стадий.
- Визуальный предел: если graph не читается — пора резать.
Итог
Режьте монолиты на доменные DAG со явными контрактами данных.
