From c263f8f600f125546f0b180fab6957960ce180c2 Mon Sep 17 00:00:00 2001 From: Vincent Driessen Date: Wed, 7 May 2014 21:21:19 +0200 Subject: [PATCH] Fix regression introduced in 0.4.3. --- rq/worker.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/rq/worker.py b/rq/worker.py index 1d39e7a..8262159 100644 --- a/rq/worker.py +++ b/rq/worker.py @@ -103,7 +103,7 @@ class Worker(object): worker._state = connection.hget(worker.key, 'state') or '?' worker._job_id = connection.hget(worker.key, 'current_job') or None if queues: - worker.queues = [self.queue_class(queue, connection=connection) + worker.queues = [cls.queue_class(queue, connection=connection) for queue in queues.split(',')] return worker