pgq.Consumer: remove hardwired cursor name

diff --git a/python/pgq/consumer.py b/python/pgq/consumer.py
index e6ae9e822f16ce9f1de16605cc65cb6f3d01288c..1f6615d40937fc2e4092094f3de5b291d6ed1c4b 100644 (file)
--- a/python/pgq/consumer.py
+++ b/python/pgq/consumer.py
@@ -58,7 +58,7 @@ class _BatchWalker(object):
         self.curs.execute(q, [self.batch_id, self.sql_cursor, self.fetch_size])
         # this will return first batch of rows
 
-        q = "fetch %d from batch_walker" % self.fetch_size
+        q = "fetch %d from %s" % (self.fetch_size, self.sql_cursor)
         while 1:
             rows = self.curs.dictfetchall()
             if not len(rows):