serialconsumer: fix batch_info usage
authorMarko Kreen <markokr@gmail.com>
Fri, 11 Feb 2011 13:29:20 +0000 (15:29 +0200)
committerMarko Kreen <markokr@gmail.com>
Fri, 11 Feb 2011 13:54:01 +0000 (15:54 +0200)
python/pgq/remoteconsumer.py

index daa087e90c84098f0d96421c9de25e2c4ffdec2c..a676b5a156b7fb00fbd68b555dfab8aba1a6e57b 100644 (file)
@@ -136,7 +136,7 @@ class SerialConsumer(Consumer):
         """Helper function to set last successful batch
         in external database.
         """
-        tick_id = self.cur_batch_info['tick_id']
+        tick_id = self.batch_info['tick_id']
         self.set_last_tick(dst_curs, tick_id)
 
     def register_consumer(self):