boki/stock-bot
1
0
Fork 0
Code Issues 1 Pull requests Projects Releases Packages Wiki Activity Actions

removed type from jobs

Browse source
This commit is contained in:
Boki 2025-06-19 08:54:43 -04:00
parent e924c8b6bc
commit 7b0c7d12fa
2 changed files with 0 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

3
libs/queue/src/batch-processor.ts
View file

@ -73,7 +73,6 @@ async function processDirect<T>(
const jobs = items.map((item, index) => ({ const jobs = items.map((item, index) => ({
name: 'process-item', name: 'process-item',
data: { data: {
type: 'process-item',
handler: options.handler || 'generic', handler: options.handler || 'generic',
operation: options.operation || 'process-item', operation: options.operation || 'process-item',
payload: item, // Just the item directly - no wrapper! payload: item, // Just the item directly - no wrapper!
@ -128,7 +127,6 @@ async function processBatched<T>(
return { return {
name: 'process-batch', name: 'process-batch',
data: { data: {
type: 'process-batch',
handler: options.handler || 'generic', handler: options.handler || 'generic',
operation: 'process-batch-items', operation: 'process-batch-items',
payload: { payload: {
@ -190,7 +188,6 @@ export async function processBatchJob(
const jobs = items.map((item: unknown, index: number) => ({ const jobs = items.map((item: unknown, index: number) => ({
name: 'process-item', name: 'process-item',
data: { data: {
type: 'process-item',
handler: options.handler || 'generic', handler: options.handler || 'generic',
operation: options.operation || 'generic', operation: options.operation || 'generic',
payload: item, // Just the item directly! payload: item, // Just the item directly!

1
libs/queue/src/types.ts
View file

@ -1,6 +1,5 @@
// Types for queue operations // Types for queue operations
export interface JobData<T = unknown> { export interface JobData<T = unknown> {
type?: string;
handler: string; handler: string;
operation: string; operation: string;
payload: T; payload: T;