code: def _compute_and_transfer_to_final_run(self, process_name, start_timeperiod, end_timeperiod, job_record):
          
          source_collection_name = context.process_context[process_name].source
          start_id = self.ds.highest_primary_key(source_collection_name, start_timeperiod, end_timeperiod)
          end_id = self.ds.lowest_primary_key(source_collection_name, start_timeperiod, end_timeperiod)
          uow, transfer_to_final = self.insert_and_publish_uow(job_record, start_id, end_id)
          self.update_job(job_record, uow, job.STATE_FINAL_RUN)
  
          if transfer_to_final:
              self._process_state_final_run(job_record)
docs: method computes new unit_of_work and transfers the job to STATE_FINAL_RUN
          it also shares _fuzzy_ DuplicateKeyError logic from _compute_and_transfer_to_progress method