From 3390df291dc6a304537c292c54d93dd6c285ab02 Mon Sep 17 00:00:00 2001
From: alikia2x <alikia2x@outlook.com>
Date: Fri, 31 Oct 2025 20:05:29 +0800
Subject: [PATCH] update: use gauge metric for all kinds of job duration info

---
 packages/crawler/metrics/index.ts                      | 5 -----
 packages/crawler/mq/exec/dispatchMilestoneSnapshots.ts | 2 +-
 packages/crawler/mq/exec/snapshotTick.ts               | 4 ++--
 3 files changed, 3 insertions(+), 8 deletions(-)

diff --git a/packages/crawler/metrics/index.ts b/packages/crawler/metrics/index.ts
index ba9dec6..b4bfbec 100644
--- a/packages/crawler/metrics/index.ts
+++ b/packages/crawler/metrics/index.ts
@@ -27,8 +27,3 @@ export const queueJobsCounter = meter.createGauge("queue_jobs_count", {
 export const jobDurationRaw = meter.createGauge("job_duration_raw", {
 	description: "Execution duration of BullMQ jobs in milliseconds"
 });
-
-export const jobDuration = meter.createHistogram("job_duration", {
-	description: "Execution duration of BullMQ jobs in milliseconds",
-	unit: "ms"
-});
diff --git a/packages/crawler/mq/exec/dispatchMilestoneSnapshots.ts b/packages/crawler/mq/exec/dispatchMilestoneSnapshots.ts
index 09be220..0d09d5d 100644
--- a/packages/crawler/mq/exec/dispatchMilestoneSnapshots.ts
+++ b/packages/crawler/mq/exec/dispatchMilestoneSnapshots.ts
@@ -6,7 +6,7 @@ import { scheduleSnapshot } from "db/snapshotSchedule";
 import logger from "@core/log";
 import { HOUR, MINUTE, SECOND } from "@core/lib";
 import { sql } from "@core/db/dbNew";
-import { jobCounter, jobDuration, jobDurationRaw } from "metrics";
+import { jobCounter, jobDurationRaw } from "metrics";
 
 export const dispatchMilestoneSnapshotsWorker = async (_job: Job) => {
 	const start = Date.now();
diff --git a/packages/crawler/mq/exec/snapshotTick.ts b/packages/crawler/mq/exec/snapshotTick.ts
index 5320fac..f813857 100644
--- a/packages/crawler/mq/exec/snapshotTick.ts
+++ b/packages/crawler/mq/exec/snapshotTick.ts
@@ -10,7 +10,7 @@ import {
 import logger from "@core/log";
 import { SnapshotQueue } from "mq/index";
 import { sql } from "@core/db/dbNew";
-import { jobCounter, jobDuration } from "metrics";
+import { jobCounter, jobDurationRaw } from "metrics";
 
 const priorityMap: { [key: string]: number } = {
 	milestone: 1,
@@ -84,7 +84,7 @@ export const snapshotTickWorker = async (_job: Job) => {
 		const duration = Date.now() - start;
 
 		jobCounter.add(1, { jobName: "snapshotTick" });
-		jobDuration.record(duration, { jobName: "snapshotTick" });
+		jobDurationRaw.record(duration, { jobName: "snapshotTick" });
 	}
 };