projects
/
skytools.git
/ commitdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
| commitdiff |
tree
raw
|
patch
| inline |
side by side
(parent:
db53e59
)
serialconsumer: fix batch_info usage
author
Marko Kreen
<markokr@gmail.com>
Fri, 11 Feb 2011 13:29:20 +0000
(15:29 +0200)
committer
Marko Kreen
<markokr@gmail.com>
Fri, 11 Feb 2011 13:54:01 +0000
(15:54 +0200)
python/pgq/remoteconsumer.py
patch
|
blob
|
blame
|
history
diff --git
a/python/pgq/remoteconsumer.py
b/python/pgq/remoteconsumer.py
index daa087e90c84098f0d96421c9de25e2c4ffdec2c..a676b5a156b7fb00fbd68b555dfab8aba1a6e57b 100644
(file)
--- a/
python/pgq/remoteconsumer.py
+++ b/
python/pgq/remoteconsumer.py
@@
-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):