Plánování na základě rozdělených assetů

Teď, když upstream emituje rozdělené události daily_sales, může na ně reportovací DAG reagovat automaticky – spustí se jen pro ten oddíl, který byl právě aktualizován, místo aby znovu zpracovával všechna data. Upstream emituje úplný timestamp, ale report pracuje jen s kalendářním datem; právě na normalizaci tohoto klíče slouží StartOfDayMapper. V tomto cvičení napláncuješ downstream report na rozdělený asset a namapuješ každou událost na příslušný den.

Upstream je v souboru předvyplněn pro přehled a oba DAGy uvidíš spolupracovat v dalším cvičení.