diff --git a/etl/customers/stonewater/Wave 3 Preparation.py b/etl/customers/stonewater/Wave 3 Preparation.py index 8a00604b..7cbf04f1 100644 --- a/etl/customers/stonewater/Wave 3 Preparation.py +++ b/etl/customers/stonewater/Wave 3 Preparation.py @@ -3382,6 +3382,13 @@ def revised_model(): to_filter = filtered["survey_folder"].str.replace(r"[^\w\s]", "").str.contains( home["Name"].replace(r"[^\w\s]", "").replace("Flat", "").lstrip(), case=False ) + + if to_filter.sum() > 1: + to_filter = ( + filtered["survey_folder"].str.replace(r"[^\w\s]", "").str.split("/").str[-1].str.lower() == + home["Name"].replace(r"[^\w\s]", "").lstrip().lower() + ) + if to_filter.sum() == 0: to_filter = ( filtered["survey_folder"].