Fix TestHeadDeleteSimple to test reloaded Head too
@@ -505,7 +505,6 @@ func TestHeadDeleteSimple(t *testing.T) {
for _, compress := range []bool{false, true} {
t.Run(fmt.Sprintf("compress=%t", compress), func(t *testing.T) {
- Outer:
for _, c := range cases {
dir, err := ioutil.TempDir("", "test_wal_reload")
testutil.Ok(t, err)
@@ -553,6 +552,13 @@ func TestHeadDeleteSimple(t *testing.T) {
testutil.Ok(t, reloadedHead.Init(0))
// Compare the query results for both heads - before and after the reload.
+ Outer:
+ for _, h := range []*Head{head, reloadedHead} {
+ q, err := NewBlockQuerier(h, h.MinTime(), h.MaxTime())
+ testutil.Ok(t, err)
+ actSeriesSet, ws, err := q.Select(false, nil, labels.MustNewMatcher(labels.MatchEqual, lblDefault.Name, lblDefault.Value))
+ testutil.Ok(t, err)
+ testutil.Equals(t, 0, len(ws))
expSeriesSet := newMockSeriesSet([]storage.Series{
newSeries(map[string]string{lblDefault.Name: lblDefault.Value}, func() []tsdbutil.Sample {
ss := make([]tsdbutil.Sample, 0, len(c.smplsExp))
@@ -563,12 +569,6 @@ func TestHeadDeleteSimple(t *testing.T) {
}(),
),
})
- for _, h := range []*Head{head, reloadedHead} {
- q, err := NewBlockQuerier(h, h.MinTime(), h.MaxTime())
- testutil.Ok(t, err)
- actSeriesSet, ws, err := q.Select(false, nil, labels.MustNewMatcher(labels.MatchEqual, lblDefault.Name, lblDefault.Value))
- testutil.Ok(t, err)
- testutil.Equals(t, 0, len(ws))
for {
eok, rok := expSeriesSet.Next(), actSeriesSet.Next()
