From 7579afa3c3b556866afb81dadf18e7dbe18bda10 Mon Sep 17 00:00:00 2001 From: Boki Date: Tue, 24 Jun 2025 23:20:00 -0400 Subject: [PATCH] need to fix batching --- apps/stock/data-ingestion/src/handlers/ceo/ceo.handler.ts | 6 +----- 1 file changed, 1 insertion(+), 5 deletions(-) diff --git a/apps/stock/data-ingestion/src/handlers/ceo/ceo.handler.ts b/apps/stock/data-ingestion/src/handlers/ceo/ceo.handler.ts index 3900cd6..b3e2c0f 100644 --- a/apps/stock/data-ingestion/src/handlers/ceo/ceo.handler.ts +++ b/apps/stock/data-ingestion/src/handlers/ceo/ceo.handler.ts @@ -23,28 +23,24 @@ export class CeoHandler extends BaseHandler { @Operation('update-unique-symbols-posts') @ScheduledOperation('update-unique-symbols-posts', '30 * * * *', { - priority: 5, immediately: false, description: 'Process unique CEO symbols and schedule individual jobs', payload: { action: 'get-posts' }, batch: { size: 100, - delayInHours: 1, - priority: 10, + delayInHours: 0.5, } }) updateUniqueSymbolsPosts = updateUniqueSymbols; @Operation('update-unique-symbols-shorts') @ScheduledOperation('update-unique-symbols-shorts', '0 0 * * *', { - priority: 5, immediately: false, description: 'Process unique CEO symbols and schedule individual jobs', payload: { action: 'get-shorts' }, batch: { size: 50, delayInHours: 2, - priority: 8, direct: true, // Use direct mode for shorts } })