Planificación sobre assets particionados

Ahora que el upstream emite eventos particionados de daily_sales, el Dag de reporting puede reaccionar automáticamente y ejecutarse solo para la partición que acaba de actualizarse, en lugar de reprocesar todas las fechas. El upstream emite una marca de tiempo completa, pero el informe solo necesita la fecha del calendario; normalizar esa clave es precisamente para lo que sirve StartOfDayMapper. En este ejercicio, programarás el informe downstream sobre el asset particionado y asignarás cada evento a su día.

El upstream ya está precargado en el archivo como contexto, y verás ambos Dags funcionando juntos en el siguiente ejercicio.