This should just be `self.queues[prio].append(job)`, not a separate queue per session.