From 0a4bfbe4f76788d7bfa7ccd779771b3a7f71f8dd Mon Sep 17 00:00:00 2001 From: Kaviraj Kanagaraj Date: Wed, 4 May 2022 09:59:01 +0200 Subject: [PATCH] Remove nosiy "inflight" requests log entries (#6074) We have enough metrics now (queue time, queue length and metrics.go statistics) that makes these log entries obselete. Signed-off-by: Kaviraj --- pkg/querier/worker/scheduler_processor.go | 6 ------ 1 file changed, 6 deletions(-) diff --git a/pkg/querier/worker/scheduler_processor.go b/pkg/querier/worker/scheduler_processor.go index 5a09da177d5c9..ed18897ec44d1 100644 --- a/pkg/querier/worker/scheduler_processor.go +++ b/pkg/querier/worker/scheduler_processor.go @@ -22,8 +22,6 @@ import ( "google.golang.org/grpc" "google.golang.org/grpc/health/grpc_health_v1" - "github.com/grafana/dskit/tenant" - "github.com/grafana/loki/pkg/lokifrontend/frontend/v2/frontendv2pb" querier_stats "github.com/grafana/loki/pkg/querier/stats" "github.com/grafana/loki/pkg/scheduler/schedulerpb" @@ -129,15 +127,11 @@ func (sp *schedulerProcessor) querierLoop(c schedulerpb.SchedulerForQuerier_Quer logger = util_log.WithContext(ctx, sp.log) ) - start := time.Now() - tenant, _ := tenant.TenantID(ctx) sp.metrics.inflightRequests.Inc() - level.Debug(logger).Log("msg", "tracking inflight request", "tenant", tenant, "op", "enqueue") sp.runRequest(ctx, logger, request.QueryID, request.FrontendAddress, request.StatsEnabled, request.HttpRequest) sp.metrics.inflightRequests.Dec() - level.Debug(logger).Log("msg", "tracking inflight request", "tenant", tenant, "op", "dequeue", "duration", time.Since(start)) // Report back to scheduler that processing of the query has finished. if err := c.Send(&schedulerpb.QuerierToScheduler{}); err != nil {