diff --git a/pkg/logql/metrics.go b/pkg/logql/metrics.go index d5a3f38a21f3..1399ac15ef9f 100644 --- a/pkg/logql/metrics.go +++ b/pkg/logql/metrics.go @@ -195,6 +195,12 @@ func RecordRangeAndInstantQueryMetrics( logValues = append(logValues, tagsToKeyValues(queryTags)...) + if httpreq.ExtractHeader(ctx, httpreq.LokiDisablePipelineWrappersHeader) == "true" { + logValues = append(logValues, "disable_pipeline_wrappers", "true") + } else { + logValues = append(logValues, "disable_pipeline_wrappers", "false") + } + level.Info(logger).Log( logValues..., )