Fix typo in file name and return early in DeserializeToSeriesGroup.

grafana · Sep 11, 2024 · 55fe162 · 55fe162
1 parent 57e6ddd
commit 55fe162
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 0 deletions.
diff --git a/...ote/queue/serialization/seralizer_test.go → ...te/queue/serialization/serializer_test.go b/...ote/queue/serialization/seralizer_test.go → ...te/queue/serialization/serializer_test.go
diff --git a/internal/component/prometheus/remote/queue/types/serialization.go b/internal/component/prometheus/remote/queue/types/serialization.go
@@ -246,6 +246,9 @@ func PutTimeSeriesBinary(ts *TimeSeriesBinary) {
 // DeserializeToSeriesGroup transforms a buffer to a SeriesGroup and converts the stringmap + indexes into actual Labels.
 func DeserializeToSeriesGroup(sg *SeriesGroup, buf []byte) (*SeriesGroup, []byte, error) {
 	buffer, err := sg.UnmarshalMsg(buf)
+	if err != nil {
+		return sg, nil, err
+	}
 	// Need to fill in the labels.
 	for _, series := range sg.Series {
 		if cap(series.Labels) < len(series.LabelsNames) {