From 857d61029693d863e0aadbe76b9d7e3d94f84bc7 Mon Sep 17 00:00:00 2001
From: Marko Kreen <markokr@gmail.com>
Date: Wed, 28 Apr 2010 13:05:46 +0300
Subject: [PATCH] pgq.Consumer: remove hardwired cursor name

---
 python/pgq/consumer.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/python/pgq/consumer.py b/python/pgq/consumer.py
index e6ae9e82..1f6615d4 100644
--- 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):
-- 
2.39.5