From 815173bc7966b7e6ca66015604995c8a417b4e4c Mon Sep 17 00:00:00 2001
From: Daniel Roth <daniel_roth@hotmail.co.uk>
Date: Wed, 3 Jun 2026 08:21:54 +0000
Subject: [PATCH] tweak local trigger

---
 .../trigger_pashub_sqs_from_file.py           | 62 ++++++++++---------
 1 file changed, 32 insertions(+), 30 deletions(-)

diff --git a/backend/pashub_fetcher/trigger_pashub_sqs_from_file.py b/backend/pashub_fetcher/trigger_pashub_sqs_from_file.py
index c751171a..cb6c2ffd 100644
--- a/backend/pashub_fetcher/trigger_pashub_sqs_from_file.py
+++ b/backend/pashub_fetcher/trigger_pashub_sqs_from_file.py
@@ -16,38 +16,40 @@ logger: logging.Logger = logging.getLogger(__name__)
 
 DRY_RUN: bool = False
 
-DEAL_ID_FILTER: frozenset[str] = frozenset(
-    {
-        "379452094688",
-        "379466504437",
-        "379660170452",
-        "380016925932",
-        "379848065216",
-        "379466504434",
-        "379452094690",
-        "379965924567",
-        "380016925923",
-        "379792072898",
-        "379654754502",
-        "379560262861",
-        "379969670369",
-        "379248717001",
-        "379971468493",
-        "379999888607",
-        "379606372580",
-        "379969603797",
-        "379967743213",
-        "379263155434",
-        "379855267025",
-        "379889899719",
-        "379071064307",
-        "379867925741",
-    }
-)
+# DEAL_ID_FILTER: frozenset[str] = frozenset(
+#     {
+#         "379452094688",
+#         "379466504437",
+#         "379660170452",
+#         "380016925932",
+#         "379848065216",
+#         "379466504434",
+#         "379452094690",
+#         "379965924567",
+#         "380016925923",
+#         "379792072898",
+#         "379654754502",
+#         "379560262861",
+#         "379969670369",
+#         "379248717001",
+#         "379971468493",
+#         "379999888607",
+#         "379606372580",
+#         "379969603797",
+#         "379967743213",
+#         "379263155434",
+#         "379855267025",
+#         "379889899719",
+#         "379071064307",
+#         "379867925741",
+#     }
+# )
+
+DEAL_ID_FILTER = None
 
 EXCEL_PATH: str = os.path.join(
     os.path.dirname(__file__),
-    "united-infrastructure-exports-all-deals-2026-05-14.xlsx",
+    "local_run_02-06-2026/NCHA WAVE 3 RAs.xlsx",
 )
 
 
@@ -64,7 +66,7 @@ def _build_requests(excel_path: str) -> list[PashubToAraTriggerRequest]:
     pashub_col: int = headers["PasHub link"]
     record_id_col: int = headers["Record ID"]
     deal_name_col: int = headers["Deal Name"]
-    deal_stage_col: Optional[int] = headers["Deal Stage"]
+    deal_stage_col: Optional[int] = headers.get("Deal Stage", None)
 
     requests: list[PashubToAraTriggerRequest] = []