diff --git a/pkg/rpc/scheduler/server/server.go b/pkg/rpc/scheduler/server/server.go index 067eff5756c..433ec39b06b 100644 --- a/pkg/rpc/scheduler/server/server.go +++ b/pkg/rpc/scheduler/server/server.go @@ -61,8 +61,9 @@ func (p *proxy) RegisterPeerTask(ctx context.Context, req *scheduler.PeerTaskReq if err != nil { isSuccess = false metrics.RegisterPeerTaskFailureCount.Inc() + } else { + metrics.PeerTaskCounter.WithLabelValues(resp.SizeScope.String()).Inc() } - metrics.PeerTaskCounter.WithLabelValues(resp.SizeScope.String()).Inc() logger.StatPeerLogger.Info("Register Peer Task", zap.Bool("Success", isSuccess),