From ebd8c94e70242571cb454989e7e3f5d30f257b4d Mon Sep 17 00:00:00 2001 From: Boki Date: Tue, 10 Jun 2025 22:43:51 -0400 Subject: [PATCH] added more specific batch keys --- apps/data-service/src/utils/batch-helpers.ts | 11 +++++++++-- 1 file changed, 9 insertions(+), 2 deletions(-) diff --git a/apps/data-service/src/utils/batch-helpers.ts b/apps/data-service/src/utils/batch-helpers.ts index e48aeb5..3179df8 100644 --- a/apps/data-service/src/utils/batch-helpers.ts +++ b/apps/data-service/src/utils/batch-helpers.ts @@ -176,7 +176,7 @@ async function processBatched( type: 'process-batch', service: options.service || 'generic', provider: options.provider || 'generic', - operation: options.operation || 'generic', + operation: 'process-batch-items', payload: { payloadKey, batchIndex, @@ -280,7 +280,14 @@ async function storePayload( options: ProcessOptions ): Promise { const cache = getCache(); - const key = `payload_${Date.now()}_${Math.random().toString(36).substr(2, 9)}`; + + // Create more specific key: batch:provider:operation:payload_timestamp_random + const timestamp = Date.now(); + const randomId = Math.random().toString(36).substr(2, 9); + const provider = options.provider || 'generic'; + const operation = options.operation || 'generic'; + + const key = `${provider}:${operation}:payload_${timestamp}_${randomId}`; const payload = { items,