We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 6c2f270 commit 41604c2Copy full SHA for 41604c2
aws_lambda_powertools/utilities/batch/sqs.py
@@ -126,8 +126,13 @@ def _clean(self):
126
entries_to_remove = self._get_entries_to_clean()
127
128
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)
+ while entries_to_remove:
+ # 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:]
136
137
if self.suppress_exception:
138
logger.debug(f"{len(self.fail_messages)} records failed processing, but exceptions are suppressed")
0 commit comments