From d730a90246e4cb856c37999274cf58e1723739ca Mon Sep 17 00:00:00 2001
From: Jun-te Kim <juntekim@googlemail.com>
Date: Wed, 8 Apr 2026 14:47:31 +0000
Subject: [PATCH] added coordination comments

---
 backend/address2UPRN/README.md        | 6 +++---
 backend/app/db/models/organisation.py | 1 +
 etl/hubspot/hubspotClient.py          | 1 +
 etl/hubspot/hubspotDataTodB.py        | 6 ++++++
 sfr/principal_pitch/2_export_data.py  | 8 ++++----
 5 files changed, 15 insertions(+), 7 deletions(-)

diff --git a/backend/address2UPRN/README.md b/backend/address2UPRN/README.md
index b17b36d1..6b0fc753 100644
--- a/backend/address2UPRN/README.md
+++ b/backend/address2UPRN/README.md
@@ -52,9 +52,9 @@ I uploaded the missing uprn here: s3://retrofit-data-dev/ara_raw_inputs/calico/m
 ordnance_survey sqs is => https://eu-west-2.console.aws.amazon.com/sqs/v3/home?region=eu-west-2#/queues/https%3A%2F%2Fsqs.eu-west-2.amazonaws.com%2F337213553626%2FordnanceSurvey-queue-dev
 
 {
-    "s3_uri": "s3://retrofit-data-dev/ara_raw_inputs/calico/missinguprn.csv",
-    "task_id": "a7b70a02-4df4-45b5-a50b-196e095910bb",
-    "sub_task_id": "567cf73b-1210-4909-9ecc-36ae7e23420e"
+    "s3_uri": "s3://retrofit-data-dev/ara_raw_inputs/eon/beyond_housing/Book(Sheet1).csv",
+    "task_id": "ccdec0d1-ebf3-484f-b2ae-397200dd25da",
+    "sub_task_id": "569d41f6-45cd-4e64-a586-eb8c2097375d"
 }
 
 
diff --git a/backend/app/db/models/organisation.py b/backend/app/db/models/organisation.py
index cc3ef2bc..784cc4ad 100644
--- a/backend/app/db/models/organisation.py
+++ b/backend/app/db/models/organisation.py
@@ -38,6 +38,7 @@ class HubspotDealData(SQLModel, table=True):
     major_condition_issue_evidence_s3_url: Optional[str] = Field(default=None)
 
     coordination_status: Optional[str] = Field(default=None)
+    coordination_comments: Optional[str] = Field(default=None)
     design_status: Optional[str] = Field(default=None)
 
     listing_id: Optional[str] = Field(default=None)
diff --git a/etl/hubspot/hubspotClient.py b/etl/hubspot/hubspotClient.py
index a9ea535d..dc2fc7fe 100644
--- a/etl/hubspot/hubspotClient.py
+++ b/etl/hubspot/hubspotClient.py
@@ -246,6 +246,7 @@ class HubspotClient:
                     "major_condition_issue_description",
                     "major_condition_issue_photos",
                     "coordination_status__stage_1_",
+                    "coordination_comments",
                     "retrofit_design_status",
                     "pashub_link",
                     "sharepoint_link",
diff --git a/etl/hubspot/hubspotDataTodB.py b/etl/hubspot/hubspotDataTodB.py
index 6325efc2..d7b47ef3 100644
--- a/etl/hubspot/hubspotDataTodB.py
+++ b/etl/hubspot/hubspotDataTodB.py
@@ -165,6 +165,10 @@ class HubspotDataToDb:
                 == hs_deal.get("coordination_status__stage_1_"),
                 "coordination stage 1 status mismatch",
             ),
+            soft_assert(
+                deal_in_db.coordination_comments == hs_deal.get("coordination_comments"),
+                "coordination_comments mismatch",
+            ),
             soft_assert(
                 deal_in_db.design_status == hs_deal.get("retrofit_design_status"),
                 "retrofit design mismatch",
@@ -383,6 +387,7 @@ class HubspotDataToDb:
                     "coordination_status": deal_data.get(
                         "coordination_status__stage_1_"
                     ),
+                    "coordination_comments": deal_data.get("coordination_comments"),
                     "design_status": deal_data.get("retrofit_design_status"),
                     "pashub_link": deal_data.get("pashub_link"),
                     "sharepoint_link": deal_data.get("sharepoint_link"),
@@ -490,6 +495,7 @@ class HubspotDataToDb:
                         "major_condition_issue_photos"
                     ),
                     coordination_status=deal_data.get("coordination_status__stage_1_"),
+                    coordination_comments=deal_data.get("coordination_comments"),
                     design_status=deal_data.get("retrofit_design_status"),
                     pashub_link=deal_data.get("pashub_link"),
                     sharepoint_link=deal_data.get("sharepoint_link"),
diff --git a/sfr/principal_pitch/2_export_data.py b/sfr/principal_pitch/2_export_data.py
index 3baa7a44..7c80f4dc 100644
--- a/sfr/principal_pitch/2_export_data.py
+++ b/sfr/principal_pitch/2_export_data.py
@@ -26,13 +26,13 @@ from backend.app.db.functions.materials_functions import get_materials
 from collections import defaultdict
 from sqlalchemy import func
 
-PORTFOLIO_ID = 656
-SCENARIOS = [1177]
+PORTFOLIO_ID = 632
+SCENARIOS = [1144]
 scenario_names = {
-    1177: "EPC C; Proposed Measures",
+    1144: "EPC C",
 }
 
-project_name = "Walsall Council | WH:LG"
+project_name = "Calico Project"
 
 
 def get_data(portfolio_id, scenario_ids):