Filter out 0 room properties

2026-02-07 19:15:48 +00:00 · 2026-02-07 19:15:48 +00:00 · 77e01776f5
commit 77e01776f5
parent 1caa9fe5ff
1 changed files with 6 additions and 0 deletions
--- a/pipeline/transform/join_epc_pp.py
+++ b/pipeline/transform/join_epc_pp.py
@ -36,6 +36,12 @@ def main():
            "CONSTRUCTION_AGE_BAND",
        )
        .filter(pl.col("epc_address").is_not_null())
+        .with_columns(
+            pl.when(pl.col("NUMBER_HABITABLE_ROOMS") == 0)
+            .then(None)
+            .otherwise(pl.col("NUMBER_HABITABLE_ROOMS"))
+            .alias("NUMBER_HABITABLE_ROOMS"),
+        )
        .sort("INSPECTION_DATE", descending=True)
        .group_by("epc_address", "POSTCODE")
        .first()