Fix data race of timerecord (#23524)

Signed-off-by: yah01 <yang.cen@zilliz.com>
2023-04-19 14:18:30 +08:00 · 2023-04-19 14:18:30 +08:00 · c7c89511b6
parent e9dcba3050
commit c7c89511b6
1 changed files with 1 additions and 1 deletions
--- a/internal/querynodev2/tasks/scheduler.go
+++ b/internal/querynodev2/tasks/scheduler.go
@ -45,9 +45,9 @@ func NewScheduler() *Scheduler {
 func (s *Scheduler) Add(task Task) bool {
 	switch t := task.(type) {
 	case *SearchTask:
+		t.tr.RecordSpan()
 		select {
 		case s.searchWaitQueue <- t:
-			t.tr.RecordSpan()
 			metrics.QueryNodeReadTaskUnsolveLen.WithLabelValues(fmt.Sprint(paramtable.GetNodeID())).Inc()
 		default:
 			return false