code: def _process_state_embryo(self, job_record):
          
          uow, is_duplicate = self.insert_and_publish_uow(job_record, 0, 0)
          self.update_job(job_record, uow, job.STATE_IN_PROGRESS)
docs: method that takes care of processing job records in STATE_EMBRYO state