Merge pull request #777 from Hestia-Homes/main

Dev deploy

backend/app/plan/router.py

@@ -9,6 +9,7 @@ import asyncio
 from datetime import datetime
 
 from fastapi import APIRouter, Depends
+from backend.app.db.connection import db_session
 from backend.app.db.models.tasks import SourceEnum
 from backend.app.dependencies import validate_token
 from backend.app.plan.schemas import PlanTriggerRequest
@@ -105,7 +106,9 @@ async def trigger_categorisation(
         )
 
         logger.info(
-            f"Chunk {batch_index} sent to SQS. {len(batch_property_ids)} Property IDs in batch (total {len(property_ids)}). Property IDs {min(batch_property_ids)}–{max(batch_property_ids)}. Message ID: {response.get('MessageId')}"
+            f"Chunk {batch_index} sent to SQS. {len(batch_property_ids)} Property IDs in batch (total "
+            f"{len(property_ids)}). Property IDs {min(batch_property_ids)}–{max(batch_property_ids)}. Message ID: "
+            f"{response.get('MessageId')}"
         )
 
         await asyncio.sleep(0.05)  # Small delay to avoid SQS throttling

infrastructure/terraform/lambda/engine/main.tf

@@ -45,8 +45,6 @@ module "lambda" {
       DOMAIN_NAME          = var.domain_name
       EPC_AUTH_TOKEN       = var.epc_auth_token
       GOOGLE_SOLAR_API_KEY = var.google_solar_api_key
-      
-      PREDICTIONS_BUCKET   = var.predictions_bucket # NOTE: Possible legacy
 
       # Buckets - from terraform state
       PLAN_TRIGGER_BUCKET             = data.terraform_remote_state.shared.outputs.retrofit_plan_trigger_bucket_name

infrastructure/terraform/lambda/engine/variables.tf

@@ -55,10 +55,6 @@ variable "data_bucket" {
   type = string
 }
 
-variable "predictions_bucket" {
-  type = string
-}
-
 locals {
   image_uri = "${var.ecr_repo_url}@${var.image_digest}"
 }