fix: split the error and agg metric cases for clarity (#13913)

grafana · Aug 16, 2024 · d2474fa · d2474fa
1 parent 8319d1c
commit d2474fa
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/pkg/pattern/tee_service.go b/pkg/pattern/tee_service.go
@@ -387,13 +387,17 @@ func (ts *TeeService) Duplicate(tenant string, streams []distributor.KeyedStream
 
 	for _, stream := range streams {
 		lbls, err := syntax.ParseLabels(stream.Stream.Labels)
-		if err != nil || lbls.Has(push.AggregatedMetricLabel) {
+		if err != nil {
 			level.Error(ts.logger).
 				Log("msg", "error parsing stream labels", "labels", stream.Stream.Labels, "err", err)
 
 			continue
 		}
 
+		if lbls.Has(push.AggregatedMetricLabel) {
+			continue
+		}
+
 		ts.buffersMutex.Lock()
 		ts.buffers[tenant] = append(ts.buffers[tenant], stream)
 		ts.buffersMutex.Unlock()