Skip to content

HTTPS clone URL

Subversion checkout URL

You can clone with
or
.
Download ZIP
Browse files

``get_queue`` now accepts ``async`` and ``default_timeout`` arguments.

  • Loading branch information...
commit a57ee600a18a9c7cc796efc0cbe2d8a1eab4909c 1 parent ed0cd0f
@selwin selwin authored
Showing with 3 additions and 2 deletions.
  1. +3 −2 django_rq/queues.py
View
5 django_rq/queues.py
@@ -31,11 +31,12 @@ def get_connection_by_index(index):
return get_redis_connection(QUEUES_LIST[index]['connection_config'])
-def get_queue(name='default'):
+def get_queue(name='default', default_timeout=None, async=True):
"""
Returns an rq Queue using parameters defined in ``RQ_QUEUES``
"""
- return Queue(name, connection=get_connection(name))
+ return Queue(name, default_timeout=default_timeout,
+ connection=get_connection(name), async=async)
def get_queue_by_index(index):
Please sign in to comment.
Something went wrong with that request. Please try again.