'Add a job to the queue (by job identifier), indicate that the job is ready to run.'

def put(self, job_wrapper):

    put_timer = ExecutionTimer()
    job = job_wrapper.get_job()
    job_wrapper.change_state(model.Job.states.QUEUED, flush=False, job=job)
    job_wrapper.set_job_destination(job_wrapper.job_destination, None, flush=False, job=job)
    self.sa_session.flush()
    self.mark_as_queued(job_wrapper)
    log.debug(('Job    [%s]    queued    %s' % (job_wrapper.job_id, put_timer)))
