diff --git a/etl/hubspot/scripts/scraper/main.py b/etl/hubspot/scripts/scraper/main.py index 32007cd4..86844352 100644 --- a/etl/hubspot/scripts/scraper/main.py +++ b/etl/hubspot/scripts/scraper/main.py @@ -57,8 +57,7 @@ def handler(body: dict[str, Any], context: Any) -> None: ) _trigger_pashub_fetcher(sqs_client, hubspot_deal_id, hubspot_deal) - coordination_status = (hubspot_deal.get("coordination_status__stage_1_") or "").lower() - if coordination_status in HubspotDealDiffer.COORDINATION_COMPLETE: + if (hubspot_deal.get("outcome") or "").lower() == "surveyed": logger.info( f"Triggering MagicPlan fetcher for HubSpot deal ID {hubspot_deal_id}" )