code: def get_queue_for_job(self, job):
          
          if self._queue is not None:
              return self._queue
          key = '{0}{1}'.format(self.queue_class.redis_queue_namespace_prefix,
                                job.origin)
          return self.queue_class.from_queue_key(
                  key, connection=self.connection, job_class=self.job_class)
docs: Returns a queue to put job into.