Fix regression introduced in 0.4.3.

main
Vincent Driessen 11 years ago
parent a6d9837d87
commit c263f8f600

@ -103,7 +103,7 @@ class Worker(object):
worker._state = connection.hget(worker.key, 'state') or '?' worker._state = connection.hget(worker.key, 'state') or '?'
worker._job_id = connection.hget(worker.key, 'current_job') or None worker._job_id = connection.hget(worker.key, 'current_job') or None
if queues: if queues:
worker.queues = [self.queue_class(queue, connection=connection) worker.queues = [cls.queue_class(queue, connection=connection)
for queue in queues.split(',')] for queue in queues.split(',')]
return worker return worker

Loading…
Cancel
Save