Test di integrazione con dag.test()
I test di integrità verificano il caricamento e i test unitari verificano la logica, ma nessuno dei due esegue davvero la Dag. I test di integrazione con dag.test() colmano questa lacuna eseguendo tutti i task in sequenza in un unico processo. È stata distribuita una pipeline ETL chiamata etl_output che scrive i risultati in /tmp/etl_results.json.
Scriverai un test di integrazione che esercita l'intera pipeline e ne verifica l'output.
Questo esercizio fa parte del corso
Creare data pipeline con Airflow
esercizio interattivo pratico
Trasforma la teoria in pratica con uno dei nostri esercizi interattivi
Inizia esercizio