diff --git a/etl/hubspot/hubspot_deal_differ.py b/etl/hubspot/hubspot_deal_differ.py index e5b32ce29..99950c648 100644 --- a/etl/hubspot/hubspot_deal_differ.py +++ b/etl/hubspot/hubspot_deal_differ.py @@ -210,6 +210,10 @@ class HubspotDealDiffer: new_deal=new_deal, new_project=new_project, old_deal=old_deal ): flows.append("sync_tenant_data") + if HubspotDealDiffer.check_for_abri_deal_abandonment( + new_deal=new_deal, new_project=new_project, old_deal=old_deal + ): + flows.append("abandon_job") if not flows: return None @@ -227,6 +231,9 @@ class HubspotDealDiffer: else None ), "confirmed_survey_time": new_deal.get("confirmed_survey_time"), + # Carried for the abandon flow's reason-mapping seam; harmless to + # the other flows, which ignore it. + "outcome": new_deal.get("outcome"), } @staticmethod