Integrationstestning med dag.test()

Integritetstester verifierar inläsning och enhetstester verifierar logik, men ingendera kör själva DAG:en. Integrationstester med dag.test() fyller den luckan genom att köra alla tasks sekventiellt i en enda process. En ETL-pipeline kallad etl_output har driftsatts och skriver sina resultat till /tmp/etl_results.json.

Du ska skriva ett integrationstest som kör hela pipelinen och verifierar dess utdata.