have worker use the passed-in connection if provided

9 years ago · 4326e19140
parent 4d204eed36
commit 4326e19140
1 changed files with 2 additions and 1 deletions
--- 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