From d4c4493736833826e19a935ea274abcb8a64a23c Mon Sep 17 00:00:00 2001 From: bigsheeper Date: Tue, 14 Jan 2025 16:52:04 +0800 Subject: [PATCH] update at Add() Signed-off-by: bigsheeper --- internal/querycoordv2/task/scheduler.go | 1 + 1 file changed, 1 insertion(+) diff --git a/internal/querycoordv2/task/scheduler.go b/internal/querycoordv2/task/scheduler.go index 902c8fd1bd216..c7379da43712a 100644 --- a/internal/querycoordv2/task/scheduler.go +++ b/internal/querycoordv2/task/scheduler.go @@ -287,6 +287,7 @@ func (scheduler *taskScheduler) Add(task Task) error { } scheduler.taskStats.Add(task.ID(), task) + scheduler.updateTaskMetrics() log.Ctx(task.Context()).Info("task added", zap.String("task", task.String())) task.RecordStartTs() return nil