set source and source id when creating categorisation task

This commit is contained in:
Daniel Roth 2026-03-05 11:32:54 +00:00
parent c0b2bf669c
commit 08cf930f91

View file

@ -9,6 +9,7 @@ import asyncio
from datetime import datetime
from fastapi import APIRouter, Depends
from backend.app.db.models.tasks import SourceEnum
from backend.app.dependencies import validate_token
from backend.app.plan.schemas import PlanTriggerRequest
from backend.app.config import get_settings
@ -68,6 +69,8 @@ async def trigger_categorisation(
service="plan_categorisation",
inputs=payload.model_dump(),
task_only=True,
source=SourceEnum.PORTFOLIO,
source_id=str(payload.portfolio_id),
)
# Dispatch requests to lambdas