From e2cd23134051ce6d96d20fb4177c319d45e529cc Mon Sep 17 00:00:00 2001 From: Daniel Roth Date: Thu, 5 Mar 2026 12:41:20 +0000 Subject: [PATCH 1/3] remove redundant bucket variable --- infrastructure/terraform/lambda/engine/main.tf | 2 -- 1 file changed, 2 deletions(-) diff --git a/infrastructure/terraform/lambda/engine/main.tf b/infrastructure/terraform/lambda/engine/main.tf index b6d61b46..fc90074b 100644 --- a/infrastructure/terraform/lambda/engine/main.tf +++ b/infrastructure/terraform/lambda/engine/main.tf @@ -46,8 +46,6 @@ module "lambda" { 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 DATA_BUCKET = data.terraform_remote_state.shared.outputs.retrofit_sap_data_bucket_name From 8a5d353c48278ff604a9bb2611443667e86157ad Mon Sep 17 00:00:00 2001 From: Daniel Roth Date: Thu, 5 Mar 2026 12:42:12 +0000 Subject: [PATCH 2/3] remove redundant bucket variable --- infrastructure/terraform/lambda/engine/main.tf | 2 +- infrastructure/terraform/lambda/engine/variables.tf | 4 ---- 2 files changed, 1 insertion(+), 5 deletions(-) diff --git a/infrastructure/terraform/lambda/engine/main.tf b/infrastructure/terraform/lambda/engine/main.tf index fc90074b..83d5e517 100644 --- a/infrastructure/terraform/lambda/engine/main.tf +++ b/infrastructure/terraform/lambda/engine/main.tf @@ -45,7 +45,7 @@ module "lambda" { DOMAIN_NAME = var.domain_name EPC_AUTH_TOKEN = var.epc_auth_token GOOGLE_SOLAR_API_KEY = var.google_solar_api_key - + # Buckets - from terraform state PLAN_TRIGGER_BUCKET = data.terraform_remote_state.shared.outputs.retrofit_plan_trigger_bucket_name DATA_BUCKET = data.terraform_remote_state.shared.outputs.retrofit_sap_data_bucket_name diff --git a/infrastructure/terraform/lambda/engine/variables.tf b/infrastructure/terraform/lambda/engine/variables.tf index 0a2277ff..8539a963 100644 --- a/infrastructure/terraform/lambda/engine/variables.tf +++ b/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}" } From 91cd3325e699c4c382986b12b98ef26bebcb5cbe Mon Sep 17 00:00:00 2001 From: Khalim Conn-Kowlessar Date: Thu, 5 Mar 2026 12:53:56 +0000 Subject: [PATCH 3/3] Added back in missing import --- backend/app/plan/router.py | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/backend/app/plan/router.py b/backend/app/plan/router.py index a90c391a..27151437 100644 --- a/backend/app/plan/router.py +++ b/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