Testes de integração com dag.test()

Testes de integridade verificam o carregamento e testes de unidade verificam a lógica, mas nenhum deles executa o Dag de fato. Testes de integração com dag.test() preenchem essa lacuna ao executar todas as tasks sequencialmente em um único processo. Um pipeline de ETL chamado etl_output foi implantado e grava os resultados em /tmp/etl_results.json.

Você vai escrever um teste de integração que exercita o pipeline completo e verifica sua saída.