diff --git a/orchestration/abri_orchestrator.py b/orchestration/abri_orchestrator.py index f4b82943a..0de04f0dc 100644 --- a/orchestration/abri_orchestrator.py +++ b/orchestration/abri_orchestrator.py @@ -273,7 +273,17 @@ class AbriOrchestrator: def abandon_job( self, abandonment: DealAbandonment ) -> AbandonJobOrchestrationResult: - raise NotImplementedError + job_no = self._deal_database.job_no_for_deal(abandonment.deal_id) + if job_no is None: + raise JobNoNotYetRecordedError(deal_id=abandonment.deal_id) + + return self._abri.abandon_job( + AbandonJobRequest( + job_no=job_no, + reason=abandon_reason_for_outcome(abandonment.outcome), + date_abandoned=self._clock(), + ) + ) def log_job(self, booking: ConfirmedSurveyBooking) -> LogJobOrchestrationResult: descriptions = build_job_descriptions(booking.deal_name)