diff --git a/pkg/scheduler/queue/metrics.go b/pkg/scheduler/queue/metrics.go index 1cff3a660a..7956b30471 100644 --- a/pkg/scheduler/queue/metrics.go +++ b/pkg/scheduler/queue/metrics.go @@ -9,7 +9,6 @@ type Metrics struct { queueLength *prometheus.GaugeVec // Per tenant discardedRequests *prometheus.CounterVec // Per tenant enqueueCount *prometheus.CounterVec // Per tenant and level - dequeueCount *prometheus.CounterVec // Per tenant and querier } func NewMetrics(subsystem string, registerer prometheus.Registerer) *Metrics { @@ -32,12 +31,6 @@ func NewMetrics(subsystem string, registerer prometheus.Registerer) *Metrics { Name: "enqueue_count", Help: "Total number of enqueued (sub-)queries.", }, []string{"user", "level"}), - dequeueCount: promauto.With(registerer).NewCounterVec(prometheus.CounterOpts{ - Namespace: "loki", - Subsystem: subsystem, - Name: "dequeue_count", - Help: "Total number of dequeued (sub-)queries.", - }, []string{"user", "querier"}), } } @@ -45,5 +38,4 @@ func (m *Metrics) Cleanup(user string) { m.queueLength.DeleteLabelValues(user) m.discardedRequests.DeleteLabelValues(user) m.enqueueCount.DeletePartialMatch(prometheus.Labels{"user": user}) - m.dequeueCount.DeletePartialMatch(prometheus.Labels{"user": user}) } diff --git a/pkg/scheduler/queue/queue.go b/pkg/scheduler/queue/queue.go index 9e12f67ced..8a31968a44 100644 --- a/pkg/scheduler/queue/queue.go +++ b/pkg/scheduler/queue/queue.go @@ -148,7 +148,6 @@ FindQueue: } q.metrics.queueLength.WithLabelValues(tenant).Dec() - q.metrics.dequeueCount.WithLabelValues(tenant, querierID).Inc() // Tell close() we've processed a request. q.cond.Broadcast()