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