Testy integracyjne z dag.test()
Testy integralności sprawdzają ładowanie danych, a testy jednostkowe weryfikują logikę — żadne z nich nie uruchamia jednak samego DAG-a. Testy integracyjne z dag.test() wypełniają tę lukę, wykonując wszystkie zadania sekwencyjnie w ramach jednego procesu. Wdrożono potok ETL o nazwie etl_output, który zapisuje wyniki do pliku /tmp/etl_results.json.
Napisz test integracyjny, który przejdzie przez cały potok i zweryfikuje jego wyniki.
To ćwiczenie jest częścią kursu
Budowanie potoków danych z Airflow
Interaktywne ćwiczenie praktyczne
Przekształć teorię w praktykę dzięki jednemu z naszych interaktywnych ćwiczeń
Rozpocznij ćwiczenie