Спостерігаємо, як розділені активи запускають даг нижче за потоком

Вищий за потоком sales_pipeline_v3 і нижчий за потоком sales_report з попередньої вправи розгорнуті та готові до запуску. Конвеєр продажів запускається щохвилини й під час кожного запуску генерує подію розділеного активу daily_sales, тоді як звіт цікавить лише дата; саме для цього потрібен StartOfDayMapper. Час подивитися, як вони працюють разом.

Виконайте ці кроки по черзі:

1. У поданні Dags спершу активуйте sales_report, щоб він був готовий відреагувати, коли надійде подія активу.
2. Потім активуйте sales_pipeline_v3; він працює щохвилини та під час кожного запуску надсилає подію розділеного активу daily_sales.
3. Зачекайте приблизно хвилину, доки sales_pipeline_v3 завершиться — після цього sales_report автоматично запуститься від події активу.
4. Відкрийте sales_report, перейдіть на вкладку Runs, відкрийте останній запуск і знайдіть Mapped Partition key у верхній частині деталей запуску.

---

У якому форматі дата в полі Mapped Partition key?