diff --git a/pkg/logql/stats/grpc.go b/pkg/logql/stats/grpc.go
index 0c9239987b7e..428620fa302a 100644
--- a/pkg/logql/stats/grpc.go
+++ b/pkg/logql/stats/grpc.go
@@ -90,6 +90,8 @@ func decodeTrailers(ctx context.Context) Result {
 	if !ok {
 		return res
 	}
+	collector.Lock()
+	defer collector.Unlock()
 	res.Ingester.TotalReached = int32(len(collector.trailers))
 	for _, meta := range collector.trailers {
 		ing := decodeTrailer(ctx, meta)