Worker.find_by_key now properly uses connection.

main
Selwin Ong 13 years ago
parent d7f83cd727
commit 41946d1bb3

@ -84,11 +84,12 @@ class Worker(object):
return None
name = worker_key[len(prefix):]
worker = cls([], name)
worker = cls([], name, connection=connection)
queues = connection.hget(worker.key, 'queues')
worker._state = connection.hget(worker.key, 'state') or '?'
if queues:
worker.queues = map(Queue, queues.split(','))
worker.queues = [Queue(queue, connection=connection)
for queue in queues.split(',')]
return worker

Loading…
Cancel
Save