Merge pull request #119 from selwin/worker-connection

Worker.find_by_key now properly uses connection. Thanks.
main
Vincent Driessen 13 years ago
commit c65a414e4a

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

Loading…
Cancel
Save