def METHOD_NAME(self, job):
    insert = self.jobs_t.insert().values(**{
        'id': job.id,
        'next_run_time': datetime_to_utc_timestamp(job.next_run_time),
        'job_state': pickle.dumps(job.__getstate__(), self.pickle_protocol)
    })
    try:
        self.engine.execute(insert)
    except IntegrityError:
        raise ConflictingIdError(job.id)