def get_queue(name=DEFAULT_QUEUE_NAME):
 global _queues
 fullname = add_queue_name_prefix(name)
 try:
  return _queues[fullname]
 except KeyError:
  log.debug(u'Initializing background job queue "{}"'.format(name))
  redis_conn = _connect()
  queue = _queues[fullname] = rq.Queue(fullname, connection=redis_conn)
  return queue

def get_queue ( name = DEFAULT_QUEUE_NAME ) : global _queues fullname = add_queue_name_prefix ( name ) try : return _queues [ fullname ] except KeyError : log . debug ( u'Initializing background job queue "{}"' . format ( name ) ) redis_conn = _connect ( ) queue = _queues [ fullname ] = rq . Queue ( fullname , connection = redis_conn ) return queue
returns a queue object tied to a redis connection .