Skip to content

Commit 41604c2

Browse files
committed
Delete to messages at a time. Before this problems would occur if more than 10 messages were processed that would need deleted.
1 parent 6c2f270 commit 41604c2

File tree

1 file changed

+7
-2
lines changed
  • aws_lambda_powertools/utilities/batch

1 file changed

+7
-2
lines changed

aws_lambda_powertools/utilities/batch/sqs.py

Lines changed: 7 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -126,8 +126,13 @@ def _clean(self):
126126
entries_to_remove = self._get_entries_to_clean()
127127

128128
delete_message_response = None
129-
if entries_to_remove:
130-
delete_message_response = self.client.delete_message_batch(QueueUrl=queue_url, Entries=entries_to_remove)
129+
while entries_to_remove:
130+
# Batch delete up to 10 messages at a time (SQS limit)
131+
delete_message_response = self.client.delete_message_batch(
132+
QueueUrl=queue_url,
133+
Entries=entries_to_remove[:10],
134+
)
135+
entries_to_remove = entries_to_remove[10:]
131136

132137
if self.suppress_exception:
133138
logger.debug(f"{len(self.fail_messages)} records failed processing, but exceptions are suppressed")

0 commit comments

Comments
 (0)