'Removes a job, preventing it from being run any more.'

def unschedule_job(self, job):

    self._jobstores_lock.acquire()
    try:
        for (alias, jobstore) in iteritems(self._jobstores):
            if (job in list(jobstore.jobs)):
                self._remove_job(job, alias, jobstore)
                return
    finally:
        self._jobstores_lock.release()
    raise KeyError(('Job    "%s"    is    not    scheduled    in    any    job    store' % job))
