diff --git a/apps/stock/config/config/default.json b/apps/stock/config/config/default.json index 6c28cf5..dde869a 100644 --- a/apps/stock/config/config/default.json +++ b/apps/stock/config/config/default.json @@ -77,8 +77,8 @@ "port": 6379, "db": 1 }, - "workers": 5, - "concurrency": 5, + "workers": 1, + "concurrency": 1, "enableScheduledJobs": true, "defaultJobOptions": { "attempts": 3, diff --git a/apps/stock/data-ingestion/src/handlers/qm/qm.handler.ts b/apps/stock/data-ingestion/src/handlers/qm/qm.handler.ts index e055588..0124451 100644 --- a/apps/stock/data-ingestion/src/handlers/qm/qm.handler.ts +++ b/apps/stock/data-ingestion/src/handlers/qm/qm.handler.ts @@ -5,9 +5,8 @@ import { Operation, ScheduledOperation, } from '@stock-bot/handlers'; -import type { DataIngestionServices } from '../../types'; import type { OperationRegistry } from '../../shared/operation-manager'; -import { createQMOperationRegistry } from './shared/operation-provider'; +import type { DataIngestionServices } from '../../types'; import { checkSessions, createSession, @@ -29,6 +28,7 @@ import { updatePrices, updateSymbolInfo } from './actions'; +import { createQMOperationRegistry } from './shared/operation-provider'; @Handler('qm') export class QMHandler extends BaseHandler { @@ -99,7 +99,7 @@ export class QMHandler extends BaseHandler { @Operation('update-symbol-info') updateSymbolInfo = updateSymbolInfo; - // @Disabled() + @Disabled() @ScheduledOperation('schedule-symbol-info-updates', '0 */6 * * *', { priority: 7, immediately: false, @@ -113,7 +113,7 @@ export class QMHandler extends BaseHandler { @Operation('update-financials') updateFinancials = updateFinancials; - // @Disabled() + @Disabled() @ScheduledOperation('schedule-financials-updates', '0 2 * * *', { priority: 6, immediately: false, @@ -127,7 +127,7 @@ export class QMHandler extends BaseHandler { @Operation('update-events') updateEvents = updateEvents; - // @Disabled() + @Disabled() @ScheduledOperation('schedule-events-updates', '0 3 * * *', { priority: 6, immediately: false, @@ -155,7 +155,7 @@ export class QMHandler extends BaseHandler { @Operation('update-prices') updatePrices = updatePrices; - // @Disabled() + @Disabled() @ScheduledOperation('schedule-price-updates', '0 */6 * * *', { priority: 8, immediately: false, diff --git a/apps/stock/data-ingestion/src/handlers/qm/shared/config.ts b/apps/stock/data-ingestion/src/handlers/qm/shared/config.ts index 62626c3..775418e 100644 --- a/apps/stock/data-ingestion/src/handlers/qm/shared/config.ts +++ b/apps/stock/data-ingestion/src/handlers/qm/shared/config.ts @@ -42,7 +42,7 @@ export const QM_CONFIG = { // Session management settings export const SESSION_CONFIG = { - MAX_SESSIONS: 100, + MAX_SESSIONS: 5, MAX_FAILED_CALLS: 5, SESSION_TIMEOUT: 5000, // 10 seconds API_TIMEOUT: 30000, // 15 seconds diff --git a/apps/stock/data-ingestion/src/shared/operation-manager/OperationTracker.ts b/apps/stock/data-ingestion/src/shared/operation-manager/OperationTracker.ts index 13896da..3cd4cc2 100644 --- a/apps/stock/data-ingestion/src/shared/operation-manager/OperationTracker.ts +++ b/apps/stock/data-ingestion/src/shared/operation-manager/OperationTracker.ts @@ -5,13 +5,13 @@ import type { Logger, MongoDBClient } from '@stock-bot/types'; import type { BaseOperationProvider } from './BaseOperationProvider'; import type { + BulkOperationUpdate, OperationComponentOptions, + OperationConfig, + OperationStats, OperationUpdate, StaleSymbolOptions, - BulkOperationUpdate, - OperationStats, - SymbolWithOperations, - OperationConfig + SymbolWithOperations } from './types'; /** @@ -197,7 +197,7 @@ export class OperationTracker { * Bulk update symbol operations for performance */ async bulkUpdateSymbolOperations(updates: BulkOperationUpdate[]): Promise { - if (updates.length === 0) return; + if (updates.length === 0) {return;} const { collectionName, symbolField, name: providerName } = this.provider.getProviderConfig();