Skip to content

Commit 6693725

Browse files
authored
log when a request starts running in querier (#6525)
* log when a request starts running in querier Signed-off-by: Ahmed Hassan <[email protected]> * log when a request starts running in querier for frontend processor Signed-off-by: Ahmed Hassan <[email protected]> --------- Signed-off-by: Ahmed Hassan <[email protected]>
1 parent 4477add commit 6693725

File tree

2 files changed

+6
-0
lines changed

2 files changed

+6
-0
lines changed

pkg/querier/worker/frontend_processor.go

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -142,6 +142,9 @@ func (fp *frontendProcessor) runRequest(ctx context.Context, request *httpgrpc.H
142142
}
143143
ctx = util_log.ContextWithHeaderMap(ctx, headerMap)
144144
logger := util_log.WithContext(ctx, fp.log)
145+
if statsEnabled {
146+
level.Info(logger).Log("msg", "started running request")
147+
}
145148

146149
response, err := fp.handler.Handle(ctx, request)
147150
if err != nil {

pkg/querier/worker/scheduler_processor.go

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -156,6 +156,9 @@ func (sp *schedulerProcessor) querierLoop(c schedulerpb.SchedulerForQuerier_Quer
156156
ctx = spanCtx
157157
}
158158
logger := util_log.WithContext(ctx, sp.log)
159+
if request.StatsEnabled {
160+
level.Info(logger).Log("msg", "started running request")
161+
}
159162
sp.runRequest(ctx, logger, request.QueryID, request.FrontendAddress, request.StatsEnabled, request.HttpRequest)
160163

161164
if err = ctx.Err(); err != nil {

0 commit comments

Comments
 (0)