junte/Model
1
0
Fork 0
mirror of https://github.com/Hestia-Homes/Model.git synced 2026-06-08 11:17:27 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

forgot json

Browse source
This commit is contained in:
Jun-te Kim 2026-04-01 10:15:20 +00:00
parent 093b93ec1c
commit 0f892a69d9
1 changed files with 13 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

17
etl/hubspot/scripts/scraper/main.py
View file

@ -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:
def handler(body: 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 == "":