Pianificare su asset partizionati

Ora che l'upstream emette eventi daily_sales partizionati, il Dag di reporting può reagire in automatico, eseguendosi solo per la partizione appena aggiornata invece di rielaborare ogni data. L'upstream emette un timestamp completo, ma il report è interessato solo alla data di calendario; normalizzare quella chiave è proprio lo scopo di StartOfDayMapper. In questo esercizio, pianificherai il report downstream sull'asset partizionato e mapperai ogni evento al suo giorno.

L'upstream è già precompilato nel file come contesto e vedrai entrambi i Dag funzionare insieme nel prossimo esercizio.