junte/Model
1
0
Fork 0
mirror of https://github.com/Hestia-Homes/Model.git synced 2026-07-12 13:29:04 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

minor refactor

Browse source
This commit is contained in:
Daniel Roth 2026-07-07 13:21:01 +00:00
parent 7b6c7e1168
commit 04b32b1515
1 changed files with 4 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -110,17 +110,10 @@ def handler(body: dict[str, Any], context: Any) -> None:
f"Triggering Pas Hub file fetcher for HubSpot deal ID {hubspot_deal_id}"
)
_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}"
)
if HubspotDealDiffer.check_for_magicplan_trigger(
new_deal=hubspot_deal, old_deal=db_deal
):
logger.info(
f"Triggering MagicPlan fetcher for HubSpot deal ID {hubspot_deal_id}"
)
_trigger_magicplan_fetcher(
sqs_client, hubspot_deal, listing, hubspot_deal_id
)
@ -139,7 +132,7 @@ def handler(body: dict[str, Any], context: Any) -> None:
f"Triggering Abri flows {abri_message['flows']} for HubSpot "
f"deal ID {hubspot_deal_id}"
)
_trigger_abri_lambda(sqs_client, abri_message)
_trigger_abri_api_lambda(sqs_client, abri_message)
print("done")
@ -150,6 +143,8 @@ def _trigger_magicplan_fetcher(
listing: Optional[dict[str, str]],
hubspot_deal_id: str,
) -> None:
logger.info(f"Triggering MagicPlan fetcher for HubSpot deal ID {hubspot_deal_id}")
message_body = {
"address": hubspot_deal.get("dealname"),
"hubspot_deal_id": hubspot_deal_id,
@ -162,7 +157,7 @@ def _trigger_magicplan_fetcher(
logger.info(f"Sent message to MagicPlan queue. MessageId: {response['MessageId']}")
def _trigger_abri_lambda(sqs_client: Any, abri_message: Dict[str, Any]) -> None:
def _trigger_abri_api_lambda(sqs_client: Any, abri_message: Dict[str, Any]) -> None:
response = sqs_client.send_message(
QueueUrl=get_settings().ABRI_SQS_URL,
MessageBody=json.dumps(abri_message),