Fix latency unit

Signed-off-by: Gao Hongtao <[email protected]>
apache · Aug 24, 2024 · 49b87c8 · 49b87c8
1 parent b8ab6e4
commit 49b87c8
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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)
 }