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 } })