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,