Inizia subitoInizia gratis

Integration testing with dag.test()

Integrity tests verify loading and unit tests verify logic, but neither runs the actual Dag. Integration tests with dag.test() fill that gap by executing all tasks sequentially in a single process. An ETL pipeline called etl_output has been deployed that writes results to /tmp/etl_results.json.

You'll write an integration test that exercises the full pipeline and verifies its output.

Questo esercizio fa parte del corso

Building Data Pipelines with Airflow

Visualizza corso

esercizio interattivo pratico

Trasforma la teoria in pratica con uno dei nostri esercizi interattivi

Inizia esercizio