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

pashub

Browse source
This commit is contained in:
Daniel Roth 2026-05-05 10:44:12 +00:00
parent f3032b9d44
commit d00d2c0e95
1 changed files with 6 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -55,7 +55,7 @@ def handler(body: dict[str, Any], context: Any) -> None:
logger.info( logger.info(
f"Triggering Pas Hub file fetcher for HubSpot deal ID {hubspot_deal_id}" f"Triggering Pas Hub file fetcher for HubSpot deal ID {hubspot_deal_id}"
) )
_trigger_pashub_fetcher(sqs_client, hubspot_deal) _trigger_pashub_fetcher(sqs_client, hubspot_deal_id, hubspot_deal)
else: else:
# Deal already in db, check whether anything has changed # Deal already in db, check whether anything has changed
logger.info( logger.info(
@ -91,7 +91,7 @@ def handler(body: dict[str, Any], context: Any) -> None:
logger.info( logger.info(
f"Triggering Pas Hub file fetcher for HubSpot deal ID {hubspot_deal_id}" f"Triggering Pas Hub file fetcher for HubSpot deal ID {hubspot_deal_id}"
) )
_trigger_pashub_fetcher(sqs_client, hubspot_deal) _trigger_pashub_fetcher(sqs_client, hubspot_deal_id, hubspot_deal)
else: else:
logger.info( logger.info(
f"Not Triggering PasHub file fetcher for HubSpot deal ID {hubspot_deal_id}" f"Not Triggering PasHub file fetcher for HubSpot deal ID {hubspot_deal_id}"
@ -100,10 +100,13 @@ def handler(body: dict[str, Any], context: Any) -> None:
print("done") print("done")
def _trigger_pashub_fetcher(sqs_client: Any, hubspot_deal: Dict[str, str]) -> None: def _trigger_pashub_fetcher(
sqs_client: Any, deal_id: str, hubspot_deal: Dict[str, str]
) -> None:
message_body: Dict[str, Optional[str]] = { message_body: Dict[str, Optional[str]] = {
"pashub_link": hubspot_deal["pashub_link"], "pashub_link": hubspot_deal["pashub_link"],
"address": None, # potentially available from Listing, leave as None for now "address": None, # potentially available from Listing, leave as None for now
"hubspot_deal_id": deal_id,
"sharepoint_link": hubspot_deal.get("sharepoint_link", None), "sharepoint_link": hubspot_deal.get("sharepoint_link", None),
"uprn": hubspot_deal.get("national_uprn", None), "uprn": hubspot_deal.get("national_uprn", None),
"landlord_property_id": hubspot_deal.get("owner_property_id", None), "landlord_property_id": hubspot_deal.get("owner_property_id", None),