diff --git a/etl/hubspot/scripts/scraper/main.py b/etl/hubspot/scripts/scraper/main.py index 570461d7..459ea5c2 100644 --- a/etl/hubspot/scripts/scraper/main.py +++ b/etl/hubspot/scripts/scraper/main.py @@ -10,16 +10,25 @@ from etl.hubspot.hubspotClient import HubspotClient from etl.hubspot.hubspotDataTodB import HubspotDataToDb from typing import Any +import json # @subtask_handler() TODO: Do this without subtask_handler but task_handler() that creates task_id and subtask_id def handler(event: dict[str, Any], context: Any, local: bool = False) -> None: if local is True: - body = { - "hubspot_deal_id": "409487859944", + event = { + "Records": [ + { + "body": json.dumps( + { + "hubspot_deal_id": "409487859944", + } + ) + } + ] } - body = event["Records"][0]["body"] + body = json.loads(event["Records"][0]["body"]) hubspot_deal_id = body.get("hubspot_deal_id", "") if hubspot_deal_id == "":