chore: remove schedulers (#5895)

Unleash · Jan 15, 2024 · 3e186f1 · 3e186f1
1 parent 1c84a81
commit 3e186f1
Show file tree

Hide file tree

Showing 4 changed files with 9 additions and 16 deletions.
diff --git a/src/lib/__snapshots__/create-config.test.ts.snap b/src/lib/__snapshots__/create-config.test.ts.snap
@@ -29,6 +29,7 @@ exports[`should create default config 1`] = `
     "enabled": true,
     "maxAge": 3600000,
   },
+  "dailyMetricsStorageDays": 31,
   "db": {
     "acquireConnectionTimeout": 30000,
     "applicationName": "unleash",

diff --git a/src/lib/create-config.ts b/src/lib/create-config.ts
@@ -551,6 +551,11 @@ export function createConfig(options: IUnleashOptions): IUnleashConfig {
 
     const feedbackUriPath = process.env.FEEDBACK_URI_PATH;
 
+    const dailyMetricsStorageDays = Math.min(
+        parseEnvVarNumber(process.env.DAILY_METRICS_STORAGE_DAYS, 31),
+        92,
+    );
+
     return {
         db,
         session,
@@ -587,6 +592,7 @@ export function createConfig(options: IUnleashOptions): IUnleashConfig {
         metricsRateLimiting,
         rateLimiting,
         feedbackUriPath,
+        dailyMetricsStorageDays,
     };
 }
 

diff --git a/src/lib/features/scheduler/schedule-services.ts b/src/lib/features/scheduler/schedule-services.ts
@@ -145,22 +145,6 @@ export const scheduleServices = async (
         'clearMetrics',
     );
 
-    schedulerService.schedule(
-        () => {
-            clientMetricsServiceV2.clearDailyMetrics(92).catch(console.error);
-        },
-        hoursToMilliseconds(24),
-        'clearDailyMetrics',
-    );
-
-    schedulerService.schedule(
-        () => {
-            clientMetricsServiceV2.aggregateDailyMetrics().catch(console.error);
-        },
-        hoursToMilliseconds(24),
-        'aggregateDailyMetrics',
-    );
-
     schedulerService.schedule(
         accountService.updateLastSeen.bind(accountService),
         minutesToMilliseconds(3),

diff --git a/src/lib/types/option.ts b/src/lib/types/option.ts
@@ -133,6 +133,7 @@ export interface IUnleashOptions {
     publicFolder?: string;
     disableScheduler?: boolean;
     metricsRateLimiting?: Partial<IMetricsRateLimiting>;
+    dailyMetricsStorageDays?: number;
     rateLimiting?: Partial<IRateLimiting>;
 }
 
@@ -236,6 +237,7 @@ export interface IUnleashConfig {
     segmentValuesLimit: number;
     strategySegmentsLimit: number;
     metricsRateLimiting: IMetricsRateLimiting;
+    dailyMetricsStorageDays: number;
     clientFeatureCaching: IClientCachingOption;
     accessControlMaxAge: number;
     prometheusApi?: string;