junte/Model
1
0
Fork 0
mirror of https://github.com/Hestia-Homes/Model.git synced 2026-06-30 13:10:47 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

tweak local trigger

Browse source
This commit is contained in:
Daniel Roth 2026-06-03 08:21:54 +00:00 • committed by Jun-te Kim
parent 35b65d0d8d
commit 815173bc79
1 changed files with 32 additions and 30 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

62
backend/pashub_fetcher/trigger_pashub_sqs_from_file.py
View file

@ -16,38 +16,40 @@ logger: logging.Logger = logging.getLogger(__name__)
DRY_RUN: bool = False DRY_RUN: bool = False
DEAL_ID_FILTER: frozenset[str] = frozenset( # DEAL_ID_FILTER: frozenset[str] = frozenset(
{ # {
"379452094688", # "379452094688",
"379466504437", # "379466504437",
"379660170452", # "379660170452",
"380016925932", # "380016925932",
"379848065216", # "379848065216",
"379466504434", # "379466504434",
"379452094690", # "379452094690",
"379965924567", # "379965924567",
"380016925923", # "380016925923",
"379792072898", # "379792072898",
"379654754502", # "379654754502",
"379560262861", # "379560262861",
"379969670369", # "379969670369",
"379248717001", # "379248717001",
"379971468493", # "379971468493",
"379999888607", # "379999888607",
"379606372580", # "379606372580",
"379969603797", # "379969603797",
"379967743213", # "379967743213",
"379263155434", # "379263155434",
"379855267025", # "379855267025",
"379889899719", # "379889899719",
"379071064307", # "379071064307",
"379867925741", # "379867925741",
} # }
) # )
DEAL_ID_FILTER = None
EXCEL_PATH: str = os.path.join( EXCEL_PATH: str = os.path.join(
os.path.dirname(__file__), 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"] pashub_col: int = headers["PasHub link"]
record_id_col: int = headers["Record ID"] record_id_col: int = headers["Record ID"]
deal_name_col: int = headers["Deal Name"] 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] = [] requests: list[PashubToAraTriggerRequest] = []