fix ParsingPoolBacklog

housepower · Apr 29, 2021 · cd6deec · cd6deec
1 parent 264ce1f
commit cd6deec
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/task/task.go b/task/task.go
@@ -230,6 +230,7 @@ func (service *Service) put(msg model.InputMessage) {
 		var row *model.Row
 		var foundNewKeys bool
 		var metric model.Metric
+		defer statistics.ParsingPoolBacklog.WithLabelValues(taskCfg.Name).Dec()
 		p := service.pp.Get()
 		metric, err = p.Parse(msg.Value)
 		if err == nil {