fix(session-ingest): extend queue retry delay (#3709)

Author: johnnyeric

services/session-ingest/src/queue-consumer.test.ts

@@ -44,7 +44,12 @@ vi.mock('./util/ingest-limits', () => ({
 import { getWorkerDb } from '@kilocode/db/client';
 import { getSessionIngestDO } from './dos/SessionIngestDO';
 import { notifyUserSessionEvent } from './session-events';
-import { computeSessionMetadataUpdates, createItemExtractor, queue } from './queue-consumer';
+import {
+  QUEUE_RETRY_DELAY_SECONDS,
+  computeSessionMetadataUpdates,
+  createItemExtractor,
+  queue,
+} from './queue-consumer';
 
 const encoder = new TextEncoder();
 
@@ -176,7 +181,7 @@ describe('queue', () => {
     );
 
     expect(ack).not.toHaveBeenCalled();
-    expect(retry).toHaveBeenCalledWith({ delaySeconds: 60 });
+    expect(retry).toHaveBeenCalledWith({ delaySeconds: QUEUE_RETRY_DELAY_SECONDS });
   });
 
   it('passes full parsed oversized message data and its R2 reference into ingest', async () => {

services/session-ingest/src/queue-consumer.ts

@@ -20,6 +20,8 @@ export interface IngestQueueMessage {
   ingestedAt: number;
 }
 
+export const QUEUE_RETRY_DELAY_SECONDS = 5 * 60;
+
 function elapsedMs(startedAt: number): number {
   return Date.now() - startedAt;
 }
@@ -540,7 +542,7 @@ export async function queue(
         sessionId: msg.body.sessionId,
         error: err instanceof Error ? err.message : String(err),
       });
-      msg.retry({ delaySeconds: 60 });
+      msg.retry({ delaySeconds: QUEUE_RETRY_DELAY_SECONDS });
     }
   }
 }