From a1a445f6f270f62b148e7d3f79eace348213e893 Mon Sep 17 00:00:00 2001
From: Daniel Roth <daniel_roth@hotmail.co.uk>
Date: Fri, 8 May 2026 13:06:43 +0000
Subject: [PATCH] =?UTF-8?q?Add=20MagicPlan=20SQS=20trigger=20to=20HubSpot?=
 =?UTF-8?q?=20orchestrator=20=F0=9F=9F=A9?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 etl/hubspot/scripts/scraper/main.py | 12 +++++++++++-
 1 file changed, 11 insertions(+), 1 deletion(-)

diff --git a/etl/hubspot/scripts/scraper/main.py b/etl/hubspot/scripts/scraper/main.py
index cd76e26f..a39e8b37 100644
--- a/etl/hubspot/scripts/scraper/main.py
+++ b/etl/hubspot/scripts/scraper/main.py
@@ -118,7 +118,17 @@ def handler(body: dict[str, Any], context: Any) -> None:
 def _trigger_magicplan_fetcher(
     sqs_client: Any, hubspot_deal: Dict[str, str], listing: Optional[dict[str, str]]
 ) -> None:
-    raise NotImplementedError
+    message_body = {
+        "address": hubspot_deal.get("dealname"),
+        "uprn": listing.get("national_uprn") if listing else None,
+    }
+    response = sqs_client.send_message(
+        QueueUrl=get_settings().MAGICPLAN_SQS_URL,
+        MessageBody=json.dumps(message_body),
+    )
+    logger.info(
+        f"Sent message to MagicPlan queue. MessageId: {response['MessageId']}"
+    )
 
 
 def _trigger_pashub_fetcher(