Skip to content

Commit dbcdde6

Browse files
committed
Remove unused method
1 parent 5502043 commit dbcdde6

File tree

1 file changed

+0
-3
lines changed
  • localstack-core/localstack/services/lambda_/event_source_mapping/pollers

1 file changed

+0
-3
lines changed

localstack-core/localstack/services/lambda_/event_source_mapping/pollers/stream_poller.py

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -205,9 +205,6 @@ def poll_events_from_shard(self, shard_id: str, shard_iterator: str):
205205
and not self._is_shutdown.is_set()
206206
):
207207
try:
208-
if self.has_record_expired(polled_events[-1]):
209-
abort_condition = "RecordAgeExpired"
210-
211208
if attempts > 0:
212209
# TODO: Should we always backoff (with jitter) before processing since we may not want multiple pollers
213210
# all starting up and polling simultaneously

0 commit comments

Comments
 (0)