diff --git a/pipeline/transform/models/staging/stg_ofsted_inspections.sql b/pipeline/transform/models/staging/stg_ofsted_inspections.sql index 9a22b65..100e6e1 100644 --- a/pipeline/transform/models/staging/stg_ofsted_inspections.sql +++ b/pipeline/transform/models/staging/stg_ofsted_inspections.sql @@ -36,7 +36,8 @@ renamed as ( report_url from source where urn is not null - and inspection_date is not null + and nullif(trim(inspection_date), 'NULL') is not null ) select * from renamed +where inspection_date is not null