The deal database gateway reads back a deal's recorded job_no 🟩

Co-Authored-By: Claude Fable 5 <noreply@anthropic.com>
This commit is contained in:
Daniel Roth 2026-07-07 09:55:24 +00:00
parent 2b29a2412b
commit 3e11dc54e5

View file

@ -26,7 +26,8 @@ class DealDatabasePostgresGateway:
self._session.commit()
def job_no_for_deal(self, deal_id: str) -> Optional[str]:
raise NotImplementedError
deal = self._find_deal(deal_id)
return deal.job_no if deal is not None else None
def _find_deal(self, deal_id: str) -> Optional[HubspotDealData]:
statement = select(HubspotDealData).where(HubspotDealData.deal_id == deal_id)