def METHOD_NAME(self, worker):
    # We have one task running right now.
    worker.future_job_mapping = {"job_id": "future"}
    job = Job(id, args=(10,))
    worker.storage.enqueue_job(job, QUEUE, Priority.HIGH)
    job = worker.get_next_job()
    worker.future_job_mapping.clear()
    # Worker must get this job since its a 'high' priority job.
    assert isinstance(job, Job) is True