From 8dfdd452ef956ec584f561f5fa277c308323f8a4 Mon Sep 17 00:00:00 2001 From: Vincent Driessen Date: Tue, 15 Nov 2011 01:34:38 +0100 Subject: [PATCH] Bugfix. Yeah, it's getting late. It's my own fault. I know. --- rq/worker.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/rq/worker.py b/rq/worker.py index ee9ae3f..def0230 100644 --- a/rq/worker.py +++ b/rq/worker.py @@ -54,7 +54,7 @@ class Worker(object): for queue in queues: value = conn.lpop(queue) if value is not None: - return value + return (queue, value) return None def pop_next_job(self, blocking): @@ -65,7 +65,7 @@ class Worker(object): value = self.multi_lpop(queues) if value is None: raise NoMoreWorkError('No more work.') - queue, msg = queue, value + queue, msg = value return (queue, msg) def work(self, quit_when_done=False):