diff --git a/pkg/querier/worker/frontend_processor.go b/pkg/querier/worker/frontend_processor.go index 3bdaa0e9a22..17bd031acfb 100644 --- a/pkg/querier/worker/frontend_processor.go +++ b/pkg/querier/worker/frontend_processor.go @@ -142,6 +142,9 @@ func (fp *frontendProcessor) runRequest(ctx context.Context, request *httpgrpc.H } ctx = util_log.ContextWithHeaderMap(ctx, headerMap) logger := util_log.WithContext(ctx, fp.log) + if statsEnabled { + level.Info(logger).Log("msg", "started running request") + } response, err := fp.handler.Handle(ctx, request) if err != nil { diff --git a/pkg/querier/worker/scheduler_processor.go b/pkg/querier/worker/scheduler_processor.go index 04d71cc69c7..aea9820153b 100644 --- a/pkg/querier/worker/scheduler_processor.go +++ b/pkg/querier/worker/scheduler_processor.go @@ -156,6 +156,9 @@ func (sp *schedulerProcessor) querierLoop(c schedulerpb.SchedulerForQuerier_Quer ctx = spanCtx } logger := util_log.WithContext(ctx, sp.log) + if request.StatsEnabled { + level.Info(logger).Log("msg", "started running request") + } sp.runRequest(ctx, logger, request.QueryID, request.FrontendAddress, request.StatsEnabled, request.HttpRequest) if err = ctx.Err(); err != nil {