Sledování, jak partitioned assety spouštějí navazující Dag

Upstream Dag sales_pipeline_v3 a downstream Dag sales_report z předchozího cvičení jsou nasazené a připravené ke spuštění. Pipeline se spouští každou minutu a při každém běhu emituje partitioned událost daily_sales — report zajímá jen datum, a přesně k tomu slouží StartOfDayMapper. Teď se podíváme, jak spolupracují.

Postupuj podle těchto kroků:

1. V zobrazení Dags nejdřív aktivuj sales_report, aby byl připravený reagovat, jakmile dorazí asset událost.
2. Pak aktivuj sales_pipeline_v3 — spouští se každou minutu a při každém běhu emituje partitioned událost daily_sales.
3. Počkej asi minutu, než sales_pipeline_v3 dokončí běh — sales_report se pak automaticky spustí na základě asset události.
4. Otevři sales_report, přejdi na záložku Runs, otevři poslední běh a nahoře v detailech běhu najdi Mapped Partition key.

---

Jaký formát data má Mapped Partition key?