From 185bf7566d4840addce7a293279afc8299e8f217 Mon Sep 17 00:00:00 2001 From: Maha Benzekri Date: Thu, 7 Nov 2024 09:50:42 +0100 Subject: [PATCH] wip --- extensions/mongoProcessor/MongoQueueProcessor.js | 5 ----- 1 file changed, 5 deletions(-) diff --git a/extensions/mongoProcessor/MongoQueueProcessor.js b/extensions/mongoProcessor/MongoQueueProcessor.js index bfe2cd549..65665c837 100644 --- a/extensions/mongoProcessor/MongoQueueProcessor.js +++ b/extensions/mongoProcessor/MongoQueueProcessor.js @@ -20,9 +20,6 @@ const getContentType = require('./utils/contentTypeHelper'); const BucketMemState = require('./utils/BucketMemState'); const MongoProcessorMetrics = require('./MongoProcessorMetrics'); -// batch metrics by location and send to kafka metrics topic every 5 seconds -const METRIC_REPORT_INTERVAL_MS = process.env.CI === 'true' ? 1000 : 5000; - // TODO - ADD PREFIX BASED ON SOURCE // april 6, 2018 @@ -480,8 +477,6 @@ class MongoQueueProcessor { } - - /** * Get bucket info in memoize state if exists, otherwise fetch from Mongo * @param {ObjectQueueEntry} sourceEntry - object metadata entry