Merge pull request #6023 from netchampfaris/async-keyword-fix

fix(async): Pass async param using dict
This commit is contained in:
Faris Ansari 2018-08-28 18:50:24 +05:30 committed by GitHub
commit c564b4b00a
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23

View file

@ -202,7 +202,12 @@ def get_queue(queue, is_async=True):
'''Returns a Queue object tied to a redis connection'''
validate_queue(queue)
return Queue(queue, connection=get_redis_conn(), is_async=is_async)
kwargs = {
'connection': get_redis_conn(),
'async': is_async
}
return Queue(queue, **kwargs)
def validate_queue(queue, default_queue_list=None):
if not default_queue_list: