From 7b0c7d12fa3a2f47451ade69925b60491bc6675d Mon Sep 17 00:00:00 2001 From: Boki Date: Thu, 19 Jun 2025 08:54:43 -0400 Subject: [PATCH] removed type from jobs --- libs/queue/src/batch-processor.ts | 3 --- libs/queue/src/types.ts | 1 - 2 files changed, 4 deletions(-) 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;