Merge pull request #1202 from Hestia-Homes/bug/magicplan-task-handler

Use correct task handler decorator for magicplan
This commit is contained in:
Daniel Roth 2026-06-09 13:36:12 +01:00 committed by GitHub
commit e11ab85d9d
No known key found for this signature in database
GPG key ID: B5690EEEBB952194

View file

@ -1,21 +1,21 @@
import os
import boto3
from typing import Any, Optional
import boto3
from applications.magic_plan.magic_plan_trigger_request import MagicPlanTriggerRequest
from infrastructure.magic_plan.config import MagicPlanConfig
from infrastructure.magic_plan.magic_plan_client import MagicPlanClient
from infrastructure.s3.s3_client import S3Client
from orchestration.magic_plan_orchestrator import MagicPlanOrchestrator
from applications.magic_plan.magic_plan_trigger_request import MagicPlanTriggerRequest
from domain.magicplan.models import Plan
from utilities.aws_lambda.subtask_handler import subtask_handler
from domain.tasks.tasks import Source
from utilities.aws_lambda.task_handler import task_handler
from utilities.logger import setup_logger
logger = setup_logger()
@subtask_handler()
@task_handler(task_source="magic_plan", source=Source.HUBSPOT_DEAL)
def handler(body: dict[str, Any], context: Any) -> Optional[str]:
config = MagicPlanConfig.from_env(os.environ)
payload = MagicPlanTriggerRequest.model_validate(body)