Adding column-level quality checks
A pipeline that loads bad data on schedule is worse than one that fails loudly. Before downstream teams consume daily_summary, you'll add a column-level quality gate that runs right after the load and rejects the run if revenue dips below zero or order counts go missing.
The load task and SQL file are pre-filled from previous lessons.
This exercise is part of the course
Building Data Pipelines with Airflow
Hands-on interactive exercise
Turn theory into action with one of our interactive exercises
Start Exercise