From 04b32b1515ac785257f0c9991f01d9e39bb57808 Mon Sep 17 00:00:00 2001 From: Daniel Roth Date: Tue, 7 Jul 2026 13:21:01 +0000 Subject: [PATCH] minor refactor --- etl/hubspot/scripts/scraper/main.py | 13 ++++--------- 1 file changed, 4 insertions(+), 9 deletions(-) diff --git a/etl/hubspot/scripts/scraper/main.py b/etl/hubspot/scripts/scraper/main.py index 69480cfa4..cd78b70c5 100644 --- a/etl/hubspot/scripts/scraper/main.py +++ b/etl/hubspot/scripts/scraper/main.py @@ -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),