Urmărind cum asset-urile partiționate declanșează un Dag din aval

Dag-urile sales_pipeline_v3 (din amonte) și sales_report (din aval) din exercițiul anterior sunt implementate și gata de rulare. Pipeline-ul de vânzări rulează în fiecare minut și emite un eveniment daily_sales partițio­nat la fiecare rulare, iar raportul ține cont doar de dată — exact pentru asta există StartOfDayMapper. E momentul să le urmărești cum lucrează împreună.

Urmează acești pași în ordine:

1. În vizualizarea Dags, activează sales_report mai întâi, astfel încât să fie pregătit să reacționeze când sosește evenimentul de asset.
2. Apoi activează sales_pipeline_v3; rulează în fiecare minut și emite un eveniment daily_sales partițio­nat la fiecare rulare.
3. Așteaptă aproximativ un minut ca sales_pipeline_v3 să se finalizeze — sales_report se va declanșa automat pe baza evenimentului de asset.
4. Deschide sales_report, accesează tab-ul Runs, deschide cea mai recentă rulare și găsește Mapped Partition key în partea de sus a detaliilor rulării.

---

Care este formatul datei pentru Mapped Partition key?