@@ -43,29 +43,6 @@ function chunkArray<T>(items: T[], size: number): T[][] {
4343 }
4444 return chunks ;
4545}
46-
47- // Summarizes a task-identifier -> items grouping for logging, without including the items
48- // themselves (each item is `{ task, payload, options }`, and `options.metadata` is arbitrary
49- // customer data that must never be written to logs whole).
50- export function summarizeItemsByTask ( itemsByTask : Record < string , unknown [ ] > ) : {
51- taskIdentifiers : string [ ] ;
52- itemCountsByTask : Record < string , number > ;
53- totalItemCount : number ;
54- } {
55- const itemCountsByTask : Record < string , number > = { } ;
56- let totalItemCount = 0 ;
57-
58- for ( const [ taskIdentifier , items ] of Object . entries ( itemsByTask ) ) {
59- itemCountsByTask [ taskIdentifier ] = items . length ;
60- totalItemCount += items . length ;
61- }
62-
63- return {
64- taskIdentifiers : Object . keys ( itemsByTask ) ,
65- itemCountsByTask,
66- totalItemCount,
67- } ;
68- }
6946const ASYNC_BATCH_PROCESS_SIZE_THRESHOLD = 20 ;
7047const MAX_ATTEMPTS = 10 ;
7148
@@ -432,11 +409,6 @@ export class BatchTriggerV3Service extends BaseService {
432409 { } as Record < string , typeof body . items >
433410 ) ;
434411
435- logger . debug (
436- "[BatchTriggerV2][call] Grouped items by task identifier" ,
437- summarizeItemsByTask ( itemsByTask )
438- ) ;
439-
440412 const idempotencyKeyLookups = Object . entries ( itemsByTask ) . flatMap ( ( [ taskIdentifier , items ] ) => {
441413 const idempotencyKeys = Array . from (
442414 new Set (
0 commit comments