diff options
Diffstat (limited to 'python')
| -rw-r--r-- | python/pgq/consumer.py | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/python/pgq/consumer.py b/python/pgq/consumer.py index bd49dccf..8160f1d1 100644 --- a/python/pgq/consumer.py +++ b/python/pgq/consumer.py @@ -334,6 +334,8 @@ class SerialConsumer(Consumer): return False if prev_tick < dst_tick: + if dst_tick - prev_tick > 5: + raise Exception('Difference too big, skipping dangerous') self.log.warning('Got tick %d, dst has %d - skipping' % (prev_tick, dst_tick)) return True else: |