Decrement pending sample when queue exits.

Signed-off-by: Tom Wilkie <tom.wilkie@gmail.com>
6 years ago · f795942572
1 changed files with 1 additions and 0 deletions
--- 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