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

Merge pull request #1048 from Hestia-Homes/feature/always-include-hs-deal-id-in-uploaded-files

Browse source 
Always include hubspot deal ID when triggering pashub file fetcher
This commit is contained in:
Daniel Roth 2026-05-05 11:49:42 +01:00 • committed by GitHub
commit 39cec2185d
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
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(
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:
# Deal already in db, check whether anything has changed
logger.info(
@ -91,7 +91,7 @@ def handler(body: dict[str, Any], context: Any) -> None:
logger.info(
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:
logger.info(
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")
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]] = {
"pashub_link": hubspot_deal["pashub_link"],
"address": None, # potentially available from Listing, leave as None for now
"hubspot_deal_id": deal_id,
"sharepoint_link": hubspot_deal.get("sharepoint_link", None),
"uprn": hubspot_deal.get("national_uprn", None),
"landlord_property_id": hubspot_deal.get("owner_property_id", None),