mirror of
https://github.com/prometheus/prometheus.git
synced 2025-01-12 14:27:27 -08:00
Merge pull request #13344 from prometheus/revert-13293
Revert "Adding small test update for temp dir using t.TempDir (#13293)"
This commit is contained in:
commit
1b74378a4c
|
@ -18,6 +18,7 @@ import (
|
||||||
"errors"
|
"errors"
|
||||||
"fmt"
|
"fmt"
|
||||||
"math"
|
"math"
|
||||||
|
"os"
|
||||||
"sort"
|
"sort"
|
||||||
"testing"
|
"testing"
|
||||||
"time"
|
"time"
|
||||||
|
@ -46,7 +47,9 @@ func TestMain(m *testing.M) {
|
||||||
func TestQueryConcurrency(t *testing.T) {
|
func TestQueryConcurrency(t *testing.T) {
|
||||||
maxConcurrency := 10
|
maxConcurrency := 10
|
||||||
|
|
||||||
dir := t.TempDir()
|
dir, err := os.MkdirTemp("", "test_concurrency")
|
||||||
|
require.NoError(t, err)
|
||||||
|
defer os.RemoveAll(dir)
|
||||||
queryTracker := NewActiveQueryTracker(dir, maxConcurrency, nil)
|
queryTracker := NewActiveQueryTracker(dir, maxConcurrency, nil)
|
||||||
t.Cleanup(queryTracker.Close)
|
t.Cleanup(queryTracker.Close)
|
||||||
|
|
||||||
|
|
|
@ -60,8 +60,12 @@ func TestDirLockerUsage(t *testing.T, open func(t *testing.T, data string, creat
|
||||||
|
|
||||||
for _, c := range cases {
|
for _, c := range cases {
|
||||||
t.Run(fmt.Sprintf("%+v", c), func(t *testing.T) {
|
t.Run(fmt.Sprintf("%+v", c), func(t *testing.T) {
|
||||||
tmpdir := t.TempDir()
|
tmpdir, err := os.MkdirTemp("", "test")
|
||||||
|
require.NoError(t, err)
|
||||||
|
t.Cleanup(func() {
|
||||||
|
require.NoError(t, os.RemoveAll(tmpdir))
|
||||||
|
})
|
||||||
|
|
||||||
// Test preconditions (file already exists + lockfile option)
|
// Test preconditions (file already exists + lockfile option)
|
||||||
if c.fileAlreadyExists {
|
if c.fileAlreadyExists {
|
||||||
tmpLocker, err := NewDirLocker(tmpdir, "tsdb", log.NewNopLogger(), nil)
|
tmpLocker, err := NewDirLocker(tmpdir, "tsdb", log.NewNopLogger(), nil)
|
||||||
|
@ -78,7 +82,7 @@ func TestDirLockerUsage(t *testing.T, open func(t *testing.T, data string, creat
|
||||||
|
|
||||||
// Check that the lockfile is always deleted
|
// Check that the lockfile is always deleted
|
||||||
if !c.lockFileDisabled {
|
if !c.lockFileDisabled {
|
||||||
_, err := os.Stat(locker.path)
|
_, err = os.Stat(locker.path)
|
||||||
require.True(t, os.IsNotExist(err), "lockfile was not deleted")
|
require.True(t, os.IsNotExist(err), "lockfile was not deleted")
|
||||||
}
|
}
|
||||||
})
|
})
|
||||||
|
|
Loading…
Reference in a new issue