From 2f7823d6c0375e46698fe9f512e42ffa67f64479 Mon Sep 17 00:00:00 2001 From: Daniel Roth Date: Fri, 27 Feb 2026 15:27:07 +0000 Subject: [PATCH] address final PR comments --- backend/.env.test | 1 + backend/app/config.py | 2 ++ backend/app/plan/router.py | 4 ++-- 3 files changed, 5 insertions(+), 2 deletions(-) diff --git a/backend/.env.test b/backend/.env.test index 1679f10f..34a1803d 100644 --- a/backend/.env.test +++ b/backend/.env.test @@ -19,4 +19,5 @@ PLAN_TRIGGER_BUCKET=test DATA_BUCKET=test EPC_AUTH_TOKEN=test ENGINE_SQS_URL=test +CATEGORISATION_SQS_URL=test ENERGY_ASSESSMENTS_BUCKET=test diff --git a/backend/app/config.py b/backend/app/config.py index f52a3606..26fb6b8b 100644 --- a/backend/app/config.py +++ b/backend/app/config.py @@ -16,6 +16,7 @@ def resolve_env_file() -> Optional[str]: if env == "local": env_file = backend_dir / ".env" + print("USING ENV FILE:", env_file) logger.debug("USING ENV FILE:", env_file) return str(env_file) @@ -36,6 +37,7 @@ class Settings(BaseSettings): DATA_BUCKET: str = "changeme" PLAN_TRIGGER_BUCKET: str ENGINE_SQS_URL: str = "changeme" + CATEGORISATION_SQS_URL: str = "changeme" # Third parties EPC_AUTH_TOKEN: str = "changeme" diff --git a/backend/app/plan/router.py b/backend/app/plan/router.py index 0e6b2aa3..1f19637a 100644 --- a/backend/app/plan/router.py +++ b/backend/app/plan/router.py @@ -70,7 +70,7 @@ async def trigger_categorisation( # Create task task_id, _ = TasksInterface.create_task( task_source="backend/plan/router.py:trigger_categorisation", - service="plan_engine", + service="plan_categorisation", inputs=payload.model_dump(), task_only=True, ) @@ -102,7 +102,7 @@ async def trigger_categorisation( batch_request.subtask_id = str(subtask_id) response = sqs_client.send_message( - QueueUrl="categorisation-queue-dev", + QueueUrl=settings.CATEGORISATION_SQS_URL, MessageBody=batch_request.model_dump_json(), )