From 49b87c8b3082f117c954c4904ca5b42aeb40d62c Mon Sep 17 00:00:00 2001 From: Gao Hongtao Date: Sat, 24 Aug 2024 00:17:41 +0000 Subject: [PATCH] Fix latency unit Signed-off-by: Gao Hongtao --- banyand/observability/service.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/banyand/observability/service.go b/banyand/observability/service.go index c08b9f10c..593f9b04e 100644 --- a/banyand/observability/service.go +++ b/banyand/observability/service.go @@ -246,5 +246,5 @@ func (sm *SchedulerMetrics) Collect(job string, m *timestamp.SchedulerMetrics) { sm.totalTasksStarted.Set(float64(m.TotalTasksStarted.Load()), job) sm.totalTasksFinished.Set(float64(m.TotalTasksFinished.Load()), job) sm.totalTasksPanic.Set(float64(m.TotalTasksPanic.Load()), job) - sm.totalTaskLatency.Set(float64(m.TotalTaskLatencyInNanoseconds.Load()/int64(time.Second)), job) + sm.totalTaskLatency.Set(float64(m.TotalTaskLatencyInNanoseconds.Load())/float64(time.Second), job) }