diff options
| author | Marko Kreen | 2010-06-08 11:20:30 +0000 |
|---|---|---|
| committer | Marko Kreen | 2010-06-09 14:51:07 +0000 |
| commit | 97b31e26eeb58ea6d9c45d800fb38b38784039ce (patch) | |
| tree | b24cf746d204509622cba7cfca9c5a0cfc48ded2 | |
| parent | 84c104dfc30a1cc745641803945741ae75233593 (diff) | |
pgq/cascade: when reporting batch pos problem, allow None
| -rw-r--r-- | python/pgq/cascade/consumer.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/python/pgq/cascade/consumer.py b/python/pgq/cascade/consumer.py index 0d500fcf..df9f577e 100644 --- a/python/pgq/cascade/consumer.py +++ b/python/pgq/cascade/consumer.py @@ -183,7 +183,7 @@ class CascadedConsumer(Consumer): return True # anything else means problems - raise Exception('Lost position: batch %d..%d, dst has %d' % ( + raise Exception('Lost position: batch %s..%s, dst has %s' % ( prev_tick, cur_tick, dst_tick)) def process_remote_batch(self, src_db, tick_id, event_list, dst_db): |