From 91cd3325e699c4c382986b12b98ef26bebcb5cbe Mon Sep 17 00:00:00 2001 From: Khalim Conn-Kowlessar Date: Thu, 5 Mar 2026 12:53:56 +0000 Subject: [PATCH] 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