Интеграционное тестирование с dag.test()

Тесты на целостность проверяют загрузку данных, а модульные тесты — логику, однако ни те ни другие не запускают DAG целиком. Интеграционные тесты с dag.test() восполняют этот пробел: они выполняют все задачи последовательно в рамках одного процесса. Был развёрнут ETL-пайплайн etl_output, который записывает результаты в /tmp/etl_results.json.

Вам нужно написать интеграционный тест, который запускает весь пайплайн и проверяет его вывод.