diff --git a/pipeline/plugins/extractors/tap-uk-ofsted/tap_uk_ofsted/tap.py b/pipeline/plugins/extractors/tap-uk-ofsted/tap_uk_ofsted/tap.py index 2c3471a..289e356 100644 --- a/pipeline/plugins/extractors/tap-uk-ofsted/tap_uk_ofsted/tap.py +++ b/pipeline/plugins/extractors/tap-uk-ofsted/tap_uk_ofsted/tap.py @@ -239,7 +239,7 @@ class OfstedInspectionsStream(Stream): record = {} for field, col in col_map.items(): val = row.get(col, None) - if pd.isna(val) or val == 'NULL': + if pd.isna(val): val = None record[field] = val