ÎncepețiÎncepe gratuit

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

Vezi cursul

Exercițiu interactiv practic

Transformă teoria în practică cu unul dintre exercițiile noastre interactive

Începe exercițiul