对任务函数进行单元测试
对 Airflow 代码进行单元测试的关键在于:将 @task 函数中的业务逻辑提取到独立的 Python 函数中,这样无需运行 Airflow 也能测试。您的团队已经在 dags/data_cleaning.py 中完成了这一点,编写了 clean_record 函数,用于去除姓名两侧的空白并将邮箱转换为小写。
接下来,您将为此函数补全单元测试。
本练习是课程的一部分
对 Airflow 代码进行单元测试的关键在于:将 @task 函数中的业务逻辑提取到独立的 Python 函数中,这样无需运行 Airflow 也能测试。您的团队已经在 dags/data_cleaning.py 中完成了这一点,编写了 clean_record 函数,用于去除姓名两侧的空白并将邮箱转换为小写。
接下来,您将为此函数补全单元测试。
本练习是课程的一部分