upstream/prometheus
1
0
Fork 0
mirror of https://github.com/prometheus/prometheus.git synced 2026-05-28 04:02:21 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions 4

Missing period and left over refactor

Browse source 
Signed-off-by: Kyle Eckhart <kgeckhart@users.noreply.github.com>
This commit is contained in:
Kyle Eckhart 2026-02-25 16:52:37 -05:00
parent 9c6b468ae3
commit dca993ed3c
2 changed files with 2 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
tsdb/agent/db.go
View file

@ -558,7 +558,7 @@ func (db *DB) loadWAL(r *wlog.Reader, duplicateRefToValidRef map[chunks.HeadSeri
if !created {
// We don't need to check if entry.Ref exists / if the value is not series.ref because GetOrSet
// enforces that the same labels will always get the same Ref. If we did not create a new ref
// the only possible ref it should ever be in the WAL is series.ref
// the only possible ref it should ever be in the WAL is series.ref.
duplicateRefToValidRef[entry.Ref] = series.ref
// We want to track the largest segment where we encountered the duplicate ref, so we can ensure

6
tsdb/agent/db_test.go
View file

@ -88,15 +88,11 @@ func TestDB_InvalidSeries(t *testing.T) {
})
}
func createTestAgentDB(t testing.TB, reg prometheus.Registerer, opts *Options, dir ...string) *DB {
func createTestAgentDB(t testing.TB, reg prometheus.Registerer, opts *Options) *DB {
t.Helper()
dbDir := t.TempDir()
if len(dir) > 0 && dir[0] != "" {
dbDir = dir[0]
}
rs := remote.NewStorage(promslog.NewNopLogger(), reg, startTime, dbDir, time.Second*30, nil, false)
t.Cleanup(func() {
require.NoError(t, rs.Close())