diff --git a/backend/engine/engine.py b/backend/engine/engine.py
index 9a9c30a2..3ece966b 100644
--- a/backend/engine/engine.py
+++ b/backend/engine/engine.py
@@ -542,7 +542,7 @@ async def model_engine(body: PlanTriggerRequest):
                 sheet_name=body.sheet_name,
                 header_row=0,
             )
-            logger.into("Got the plan input from excel")
+            logger.info("Got the plan input from excel")
 
             # We now handle the case where the input data is a Domna standardised assset list
             if body.file_format == "domna_asset_list":
diff --git a/etl/customers/peabody/Nov 2025 Consulting Project/h_reset_estimated_epcs.py b/etl/customers/peabody/Nov 2025 Consulting Project/h_reset_estimated_epcs.py
index 57b858ce..65843ed3 100644
--- a/etl/customers/peabody/Nov 2025 Consulting Project/h_reset_estimated_epcs.py	
+++ b/etl/customers/peabody/Nov 2025 Consulting Project/h_reset_estimated_epcs.py	
@@ -75,8 +75,8 @@ df = df.sort_values("property_id", ascending=True)
 
 agg = df.groupby("property_id").size().reset_index(name="n_plans")
 agg = agg.sort_values("n_plans", ascending=True)
-agg[agg["n_plans"] != 1]
-assert all(agg["n_plans"] == 1)
+agg[agg["n_plans"] != 2]
+assert all(agg["n_plans"] == 2)
 
 
 def delete_plan_batch(session: Session, plan_ids: list[int]):