diff --git a/tsdb/wlog/checkpoint_test.go b/tsdb/wlog/checkpoint_test.go index 7a0687aedc..90c1035229 100644 --- a/tsdb/wlog/checkpoint_test.go +++ b/tsdb/wlog/checkpoint_test.go @@ -113,6 +113,7 @@ func TestDeleteCheckpoints(t *testing.T) { } func TestCheckpoint(t *testing.T) { + t.Parallel() makeHistogram := func(i int) *histogram.Histogram { return &histogram.Histogram{ Count: 5 + uint64(i*4), diff --git a/tsdb/wlog/reader_test.go b/tsdb/wlog/reader_test.go index 0cbe882844..7d63c00013 100644 --- a/tsdb/wlog/reader_test.go +++ b/tsdb/wlog/reader_test.go @@ -314,6 +314,7 @@ func allSegments(dir string) (io.ReadCloser, error) { } func TestReaderFuzz(t *testing.T) { + t.Parallel() for name, fn := range readerConstructors { for _, compress := range compression.Types() { t.Run(fmt.Sprintf("%s,compress=%s", name, compress), func(t *testing.T) { @@ -353,6 +354,7 @@ func TestReaderFuzz(t *testing.T) { } func TestReaderFuzz_Live(t *testing.T) { + t.Parallel() logger := promslog.NewNopLogger() for _, compress := range compression.Types() { t.Run(fmt.Sprintf("compress=%s", compress), func(t *testing.T) { diff --git a/tsdb/wlog/watcher_test.go b/tsdb/wlog/watcher_test.go index 5ea4ee151d..4b8b408edc 100644 --- a/tsdb/wlog/watcher_test.go +++ b/tsdb/wlog/watcher_test.go @@ -443,6 +443,7 @@ func TestReadToEndWithCheckpoint(t *testing.T) { } func TestReadCheckpoint(t *testing.T) { + t.Parallel() pageSize := 32 * 1024 const seriesCount = 10 const samplesCount = 250 @@ -677,6 +678,7 @@ func TestCheckpointSeriesReset(t *testing.T) { } func TestRun_StartupTime(t *testing.T) { + t.Parallel() const pageSize = 32 * 1024 const segments = 10 const seriesCount = 20 diff --git a/tsdb/wlog/wlog_test.go b/tsdb/wlog/wlog_test.go index 2e73542508..758c4da4f4 100644 --- a/tsdb/wlog/wlog_test.go +++ b/tsdb/wlog/wlog_test.go @@ -369,6 +369,7 @@ func TestSegmentMetric(t *testing.T) { } func TestCompression(t *testing.T) { + t.Parallel() bootstrap := func(compressed compression.Type) string { const ( segmentSize = pageSize