diff --git a/OpenTelemetryIngest/Index.ts b/OpenTelemetryIngest/Index.ts index 6a121d63d3..868639484c 100644 --- a/OpenTelemetryIngest/Index.ts +++ b/OpenTelemetryIngest/Index.ts @@ -10,7 +10,7 @@ import logger from "Common/Server/Utils/Logger"; import Realtime from "Common/Server/Utils/Realtime"; import App from "Common/Server/Utils/StartServer"; import Telemetry from "Common/Server/Utils/Telemetry"; -import ProcessTelemetryWorker from "./Jobs/TelemetryIngest/ProcessTelemetry"; +import "./Jobs/TelemetryIngest/ProcessTelemetry"; import "ejs"; const app: ExpressApplication = Express.getExpressApp(); @@ -57,12 +57,6 @@ const init: PromiseVoidFunction = async (): Promise => { await Realtime.init(); - // Initialize telemetry processing worker - logger.debug("Initializing telemetry processing worker..."); - logger.debug( - `Telemetry worker initialized: ${ProcessTelemetryWorker ? "success" : "failed"}`, - ); - // add default routes await App.addDefaultRoutes(); } catch (err) { diff --git a/OpenTelemetryIngest/Jobs/TelemetryIngest/ProcessTelemetry.ts b/OpenTelemetryIngest/Jobs/TelemetryIngest/ProcessTelemetry.ts index e43cdd4bc0..0de447c24e 100644 --- a/OpenTelemetryIngest/Jobs/TelemetryIngest/ProcessTelemetry.ts +++ b/OpenTelemetryIngest/Jobs/TelemetryIngest/ProcessTelemetry.ts @@ -8,10 +8,9 @@ import logger from "Common/Server/Utils/Logger"; import { QueueJob, QueueName } from "Common/Server/Infrastructure/Queue"; import QueueWorker from "Common/Server/Infrastructure/QueueWorker"; import ObjectID from "Common/Types/ObjectID"; -import { Worker } from "bullmq"; // Set up the unified worker for processing telemetry queue -const worker: Worker = QueueWorker.getWorker( +QueueWorker.getWorker( QueueName.Telemetry, async (job: QueueJob): Promise => { logger.debug(`Processing telemetry ingestion job: ${job.name}`); @@ -63,5 +62,3 @@ const worker: Worker = QueueWorker.getWorker( ); logger.debug("Unified telemetry worker initialized"); - -export default worker;