rotor: increase metrics date key resolution

jitsucom · Jan 28, 2025 · 83fd7f7 · 83fd7f7
1 parent e3cea99
commit 83fd7f7
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/services/rotor/src/lib/metrics.ts b/services/rotor/src/lib/metrics.ts
@@ -158,6 +158,7 @@ export function createMetrics(
           continue;
         }
         const d = el.receivedAt || new Date();
+        const epochTime = d.getTime();
         d.setMilliseconds(0);
         d.setSeconds(0);
         // console.log(
@@ -184,7 +185,7 @@ export function createMetrics(
           return prefix + status;
         })(el);
         buffer.push({
-          key: el.metricsMeta.messageId + "_" + el.eventIndex + "_" + (el.receivedAt || new Date()).getTime(),
+          key: el.metricsMeta.messageId + "_" + el.eventIndex + "_" + epochTime,
           timestamp: d,
           ...omit(el.metricsMeta, "retries"),
           functionId: el.functionId,