From 4326e191406c0ece77d4ca3e614df57cb92bcb84 Mon Sep 17 00:00:00 2001 From: Chris Curvey Date: Tue, 22 Mar 2016 09:16:37 -0400 Subject: [PATCH] have worker use the passed-in connection if provided --- rq/worker.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/rq/worker.py b/rq/worker.py index 2a3f729..ac48bf5 100644 --- a/rq/worker.py +++ b/rq/worker.py @@ -139,7 +139,8 @@ class Worker(object): queue_class = import_attribute(queue_class) self.queue_class = queue_class - queues = [self.queue_class(name=q) if isinstance(q, string_types) else q + queues = [self.queue_class(name=q, connection=connection) + if isinstance(q, string_types) else q for q in ensure_list(queues)] self._name = name self.queues = queues