Asset-based scheduling în acțiune

Atât DAG-ul sales_producer, cât și sales_consumer din exercițiile anterioare au fost încărcate în interfața Airflow. Producătorul scrie date de vânzări și actualizează Asset-ul s3://data-lake/sales/daily.csv. Consumatorul este planificat pe baza acelui Asset.

Urmează acești pași:

1. În vizualizarea DAG-urilor, găsește atât sales_producer, cât și sales_consumer și activează-le folosind butonul de comutare.
2. Declanșează sales_producer făcând clic pe iconița de redare, selectând Single Run, apoi Trigger.
3. Așteaptă finalizarea rulării producătorului (toate task-urile verzi).
4. Verifică dacă sales_consumer a fost declanșat automat, fără să fi dat clic pe nimic.

---

După ce rularea sales_producer se finalizează, ce se întâmplă cu sales_consumer?