fix: drop expect batch (#83)

storacha · Nov 29, 2023 · e1e9cc8 · e1e9cc8
1 parent c62f758
commit e1e9cc8
Showing 1 changed file with 9 additions and 0 deletions.
diff --git a/packages/functions/src/aggregator/handle-buffer-queue-message.js b/packages/functions/src/aggregator/handle-buffer-queue-message.js
@@ -24,6 +24,15 @@ Sentry.AWSLambda.init({
  * @param {import('aws-lambda').SQSEvent} sqsEvent
  */
 async function handleBufferQueueMessage (sqsEvent) {
+  // if one we should put back in queue
+  if (sqsEvent.Records.length === 1) {
+    return {
+      batchItemFailures: sqsEvent.Records.map(r => ({
+        itemIdentifier: r.messageId
+      }))
+    }
+  }
+
   // unexpected number of records
   if (sqsEvent.Records.length !== 2) {
     return {