Enhetstestning av en task-funktion
Nyckeln till enhetstestning av Airflow-kod är att separera affärslogiken från @task-funktioner och lägga den i fristående Python-funktioner som kan testas utan att Airflow körs. Ditt team har gjort detta med funktionen clean_record i dags/data_cleaning.py, som tar bort blanksteg från namn och omvandlar e-postadresser till gemener.
Du ska slutföra enhetstesterna för den här funktionen.
Den här övningen är en del av kursen
Bygg datapipelines med Airflow
Interaktiv övning med praktiskt arbete
Gör teori till handling med en av våra interaktiva övningar
Starta övningen