Do Airflow UI byly načteny oba DAGy z předchozích cvičení: sales_producer i sales_consumer. Producer zapisuje prodejní data a aktualizuje asset s3://data-lake/sales/daily.csv. Consumer je naplánován na základě tohoto assetu.

Postupuj takto:

V přehledu DAGů najdi sales_producer i sales_consumer a aktivuj je pomocí přepínače.
Spusť sales_producer kliknutím na ikonu play, vyber Single Run a pak Trigger.
Počkej, až producerův běh skončí (všechny tasky jsou zelené).
Zkontroluj, jestli se sales_consumer spustil automaticky – bez toho, aniž bys na cokoli klikl/a.

Co se stane s sales_consumer po dokončení běhu sales_producer?

Plánování podle dat pomocí Assets

Create Your Free Account