From 116a0bc99c2fd5ca7060e2608d363d83036a09f2 Mon Sep 17 00:00:00 2001 From: Faris Ansari Date: Tue, 28 Aug 2018 18:45:56 +0530 Subject: [PATCH] fix(async): Pass async param using dict --- frappe/utils/background_jobs.py | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/frappe/utils/background_jobs.py b/frappe/utils/background_jobs.py index 9f75b1b744..daaed29cc5 100755 --- a/frappe/utils/background_jobs.py +++ b/frappe/utils/background_jobs.py @@ -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(), 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: