fix: tweak timeouts for aggregator and drop unnecessary check on buff…

…ering (#82)
storacha · Nov 29, 2023 · c62f758 · c62f758
1 parent 96d4431
commit c62f758
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 12 deletions.
diff --git a/packages/functions/src/aggregator/handle-buffer-queue-message.js b/packages/functions/src/aggregator/handle-buffer-queue-message.js
@@ -24,15 +24,6 @@ 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 {

diff --git a/stacks/aggregator-stack.js b/stacks/aggregator-stack.js
@@ -139,7 +139,8 @@ export function AggregatorStack({ stack, app }) {
         permissions: [
           aggregatorBufferStoreBucket,
           bufferQueue
-        ]
+        ],
+        timeout: '20 seconds'
       },
       deadLetterQueue: aggregatorPieceStoreHandleInsertDLQ.cdk.queue,
       cdk: {
@@ -188,7 +189,8 @@ export function AggregatorStack({ stack, app }) {
         bufferQueue,
         aggregatorBufferStoreBucket,
         aggregateOfferQueue
-      ]
+      ],
+      timeout: '20 seconds'
     },
     deadLetterQueue: bufferQueueDLQ.cdk.queue,
     cdk: {
@@ -243,7 +245,7 @@ export function AggregatorStack({ stack, app }) {
           aggregatorBufferStoreBucket,
           pieceAcceptQueue
         ],
-        timeout: '10 minutes'
+        timeout: '5 minutes'
       },
       deadLetterQueue: aggregatorAggregateStoreHandleInsertToPieceAcceptDLQ.cdk.queue,
       cdk: {