diff --git a/libs/queue/src/batch-processor.ts b/libs/queue/src/batch-processor.ts index a7627f2..689e0d6 100644 --- a/libs/queue/src/batch-processor.ts +++ b/libs/queue/src/batch-processor.ts @@ -73,7 +73,6 @@ async function processDirect( const jobs = items.map((item, index) => ({ name: 'process-item', data: { - type: 'process-item', handler: options.handler || 'generic', operation: options.operation || 'process-item', payload: item, // Just the item directly - no wrapper! @@ -128,7 +127,6 @@ async function processBatched( return { name: 'process-batch', data: { - type: 'process-batch', handler: options.handler || 'generic', operation: 'process-batch-items', payload: { @@ -190,7 +188,6 @@ export async function processBatchJob( const jobs = items.map((item: unknown, index: number) => ({ name: 'process-item', data: { - type: 'process-item', handler: options.handler || 'generic', operation: options.operation || 'generic', payload: item, // Just the item directly! diff --git a/libs/queue/src/types.ts b/libs/queue/src/types.ts index d11a05e..2706581 100644 --- a/libs/queue/src/types.ts +++ b/libs/queue/src/types.ts @@ -1,6 +1,5 @@ // Types for queue operations export interface JobData { - type?: string; handler: string; operation: string; payload: T;