From f7959425725e7615ac31225e4da15a4da2cf0909 Mon Sep 17 00:00:00 2001 From: Tom Wilkie Date: Tue, 19 Feb 2019 17:58:59 +0000 Subject: [PATCH] Decrement pending sample when queue exits. Signed-off-by: Tom Wilkie --- storage/remote/queue_manager.go | 1 + 1 file changed, 1 insertion(+) diff --git a/storage/remote/queue_manager.go b/storage/remote/queue_manager.go index 1fdb33e16b..a171e9d0ad 100644 --- a/storage/remote/queue_manager.go +++ b/storage/remote/queue_manager.go @@ -656,6 +656,7 @@ func (s *shards) runShard(ctx context.Context, i int, queue chan prompb.TimeSeri if len(pendingSamples) > 0 { level.Debug(s.qm.logger).Log("msg", "Flushing samples to remote storage...", "count", len(pendingSamples)) s.sendSamples(ctx, pendingSamples) + s.qm.pendingSamplesMetric.Sub(float64(len(pendingSamples))) level.Debug(s.qm.logger).Log("msg", "Done flushing.") } return