Asset-based scheduling w praktyce

Oba DAG-i — sales_producer i sales_consumer — z poprzednich ćwiczeń zostały załadowane do interfejsu Airflow. Producent zapisuje dane sprzedażowe i aktualizuje asset s3://data-lake/sales/daily.csv. Konsument jest zaplanowany na podstawie tego assetu.

Wykonaj poniższe kroki:

1. W widoku DAG-ów znajdź sales_producer i sales_consumer, a następnie aktywuj oba za pomocą przełącznika.
2. Uruchom sales_producer, klikając ikonę odtwarzania, wybierając Single Run, a potem Trigger.
3. Poczekaj, aż przebieg producenta dobiegnie końca (wszystkie zadania zielone).
4. Sprawdź, czy sales_consumer został wyzwolony automatycznie — bez klikania czegokolwiek.

---

Co się dzieje z sales_consumer po zakończeniu przebiegu sales_producer?