diff --git a/backend/engine/engine.py b/backend/engine/engine.py
index 3ece966b..4f5ee3c1 100644
--- a/backend/engine/engine.py
+++ b/backend/engine/engine.py
@@ -703,7 +703,8 @@ async def model_engine(body: PlanTriggerRequest):
                     property_lookup[("uprn", uprn)] = prop_id
                 if landlord_property_id:
                     property_lookup[("landlord_property_id", landlord_property_id)] = prop_id
-
+                    
+        logger.info("Processing each property for model input preparation")
         input_properties, inspections_map, eco_packages, epc_upserts = [], {}, {}, []
         for addr, config in tqdm(
             zip(addresses, plan_input),
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 65843ed3..83799eff 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"] != 2]
-assert all(agg["n_plans"] == 2)
+agg[agg["n_plans"] != 3]
+assert all(agg["n_plans"] == 3)
 
 
 def delete_plan_batch(session: Session, plan_ids: list[int]):
diff --git a/serverless.yml b/serverless.yml
index f3def028..9e57ca95 100644
--- a/serverless.yml
+++ b/serverless.yml
@@ -60,7 +60,7 @@ functions:
     image:
       uri: ${env:ECR_URI}:${env:GITHUB_SHA}
     timeout: 900
-    memorySize: 3008
+    memorySize: 4096
     role: EngineLambdaRole
     events:
       - sqs: