diff options
author | martinko | 2013-09-19 15:28:19 +0000 |
---|---|---|
committer | martinko | 2013-09-19 15:28:19 +0000 |
commit | 003f7959f8b466720647d67aaf113ca52f61f53d (patch) | |
tree | 4661bb9309250b7ebecae2967106b0eb8f95f706 /python/pgq/localconsumer.py | |
parent | 185ced570b0fee134dbf2913f02c9f5d375f1a29 (diff) |
python: amendments
Diffstat (limited to 'python/pgq/localconsumer.py')
-rw-r--r-- | python/pgq/localconsumer.py | 6 |
1 files changed, 2 insertions, 4 deletions
diff --git a/python/pgq/localconsumer.py b/python/pgq/localconsumer.py index ed791ece..e551536f 100644 --- a/python/pgq/localconsumer.py +++ b/python/pgq/localconsumer.py @@ -128,8 +128,7 @@ class LocalConsumer(BaseConsumer): raise Exception('process_local_event not implemented') def is_batch_done(self): - """Helper function to keep track of last successful batch - in external database. + """Helper function to keep track of last successful batch in external database. """ local_tick = self.load_local_tick() @@ -154,8 +153,7 @@ class LocalConsumer(BaseConsumer): prev_tick, cur_tick, local_tick)) def set_batch_done(self): - """Helper function to set last successful batch - in external database. + """Helper function to set last successful batch in external database. """ tick_id = self.batch_info['tick_id'] self.save_local_tick(tick_id) |