diff options
Diffstat (limited to 'python/pgq/consumer.py')
| -rw-r--r-- | python/pgq/consumer.py | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/python/pgq/consumer.py b/python/pgq/consumer.py index 0cd55d1d..e661dac4 100644 --- a/python/pgq/consumer.py +++ b/python/pgq/consumer.py @@ -317,6 +317,7 @@ class SerialConsumer(Consumer): in external database. """ + cur_tick = self.cur_batch_info['tick_id'] prev_tick = self.cur_batch_info['prev_tick_id'] dst_tick = self.get_last_tick(dst_curs) |