def METHOD_NAME(self, worker):
    # this job should never fail.
    job = Job(id, args=(9,))
    worker.storage.enqueue_job(job, QUEUE)
    while job.state == State.QUEUED:
        job = worker.storage.get_job(job.job_id)
        time.sleep(0.5)
    try:
        # Get the future, or pass if it has already been cleaned up.
        future = worker.future_job_mapping[job.job_id]
        future.result()
    except KeyError:
        pass
    job = worker.storage.get_job(job.job_id)
    assert job.state == State.COMPLETED