Update persistQueueLength after chunks were persisted.
This commit is contained in:
parent
5101c58f6c
commit
5ed8f6c205
|
@ -586,6 +586,7 @@ func (s *memorySeriesStorage) handlePersistQueue() {
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
chunkCount -= len(cds)
|
chunkCount -= len(cds)
|
||||||
|
s.persistQueueLength.Set(float64(chunkCount))
|
||||||
}
|
}
|
||||||
|
|
||||||
loop:
|
loop:
|
||||||
|
|
Loading…
Reference in New Issue