mirror of https://github.com/milvus-io/milvus.git
parent
4d8d34e370
commit
75adf1df98
|
@ -238,8 +238,8 @@ func (t *SearchTask) Done(err error) {
|
|||
collector.Counter.Dec(metricsinfo.ExecuteQueueType, 1)
|
||||
if len(t.others) > 0 {
|
||||
metrics.QueryNodeSearchGroupSize.WithLabelValues(fmt.Sprint(paramtable.GetNodeID())).Observe(float64(len(t.others) + 1))
|
||||
metrics.QueryNodeSearchGroupNQ.WithLabelValues(fmt.Sprint(paramtable.GetNodeID())).Observe(float64(t.originNqs[0]))
|
||||
metrics.QueryNodeSearchGroupTopK.WithLabelValues(fmt.Sprint(paramtable.GetNodeID())).Observe(float64(t.originTopks[0]))
|
||||
metrics.QueryNodeSearchGroupNQ.WithLabelValues(fmt.Sprint(paramtable.GetNodeID())).Observe(float64(t.nq))
|
||||
metrics.QueryNodeSearchGroupTopK.WithLabelValues(fmt.Sprint(paramtable.GetNodeID())).Observe(float64(t.topk))
|
||||
}
|
||||
select {
|
||||
case t.notifier <- err:
|
||||
|
|
Loading…
Reference in New Issue