From 5878e1645b2564a6cf61648b156cb545db86cdfa Mon Sep 17 00:00:00 2001 From: Nathan Crowe Date: Mon, 29 Jul 2024 21:36:44 -0400 Subject: [PATCH] Fix bug with get_records retry mentioned in issue #31 --- src/kinesis/consumer.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/src/kinesis/consumer.py b/src/kinesis/consumer.py index fe594ae..f4474e5 100644 --- a/src/kinesis/consumer.py +++ b/src/kinesis/consumer.py @@ -50,9 +50,10 @@ def loop(self): # until we complete a successful get_records call loop_status = min(( 30, - (self.retries or 1) * 2 + (self.retries * 2) or 1 )) log.debug("Retrying get_records (#%d %ds): %s", self.retries+1, loop_status, exc) + self.retries += 1 else: log.error("Client error occurred while reading: %s", exc) loop_status = False