mirror of
https://github.com/Hestia-Homes/Model.git
synced 2026-06-08 11:17:27 +00:00
Merge pull request #776 from Hestia-Homes/bug/db-session
Added back in missing import
This commit is contained in:
commit
5fd013b3d1
1 changed files with 4 additions and 1 deletions
|
|
@ -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
|
||||
|
|
|
|||
Loading…
Add table
Reference in a new issue