Add MagicPlan SQS trigger to HubSpot orchestrator 🟩

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(