diff --git a/tsdb/db.go b/tsdb/db.go index 73b87b0a5..9c15dd4c2 100644 --- a/tsdb/db.go +++ b/tsdb/db.go @@ -732,6 +732,12 @@ func (db *DB) run() { select { case <-time.After(1 * time.Minute): + db.cmtx.Lock() + if err := db.reloadBlocks(); err != nil { + level.Error(db.logger).Log("msg", "reloadBlocks", "err", err) + } + db.cmtx.Unlock() + select { case db.compactc <- struct{}{}: default: