'Submit a job for local execution.'

def submit_job(self, job):

    name = ('%s-%08d' % (job.name, job.id))
    locker = Locker()
    locker.unlock(grid_for(job))
    proc = multiprocessing.Process(target=job_runner, args=[job])
    proc.start()
    if proc.is_alive():
        log(('Submitted    job    as    process:    %d' % proc.pid))
        return proc.pid
    else:
        log(('Failed    to    submit    job    or    job    crashed    with    return    code    %d    !' % proc.exitcode))
        log('Deleting    job    file.')
        os.unlink(job_file_for(job))
        return None
