Use boto3 Kinesis WaiterConfig instead of Python retry when waiting for stream
erickpeirson opened this issue · 1 comments
erickpeirson commented
arxiv-base/arxiv/integration/kinesis/consumer/__init__.py
Lines 270 to 272 in 0bbb141
Using retry
introduces an extra layer of complexity, since boto3's waiter already implements some retry logic. Using WaiterConfig
like this is much simpler:
WaiterConfig=dict(
Delay=delay,
MaxAttempts=tries,
ExclusiveStartShardId=self.shard_id
)
bdc34 commented
No longer using kinesis.