diff --git a/services/session-ingest/src/queue-consumer.test.ts b/services/session-ingest/src/queue-consumer.test.ts index 3dbc6419f0..3dd1dc7bc8 100644 --- a/services/session-ingest/src/queue-consumer.test.ts +++ b/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 () => { diff --git a/services/session-ingest/src/queue-consumer.ts b/services/session-ingest/src/queue-consumer.ts index bed1fa9b5c..3411c45ba9 100644 --- a/services/session-ingest/src/queue-consumer.ts +++ b/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 }); } } }