Testare de integrare cu dag.test()
Testele de integritate verifică încărcarea datelor, iar testele unitare verifică logica, însă niciunul dintre ele nu rulează efectiv DAG-ul. Testele de integrare cu dag.test() acoperă acest decalaj, executând toate task-urile secvențial într-un singur proces. Un pipeline ETL numit etl_output a fost implementat și scrie rezultatele în /tmp/etl_results.json.
Vei scrie un test de integrare care exercită întregul pipeline și verifică rezultatele acestuia.
Acest exercițiu face parte din cursul
Construirea pipeline-urilor de date cu Airflow
Exercițiu interactiv practic
Transformă teoria în practică cu unul dintre exercițiile noastre interactive
Începe exercițiul