def METHOD_NAME(self, worker):
    job = Job(id, args=(9,))
    worker.storage.enqueue_job(job, QUEUE)
    while job.state != State.COMPLETED:
        job = worker.storage.get_job(job.job_id)
        time.sleep(0.5)
    assert job.state == State.COMPLETED