Disable TestBatchPool

This test is unreliable due to its dependency on timing. Disabling for now
until a better method is implemented.

Signed-off-by: Jonathon Anderson <janderson@ciq.co>
This commit is contained in:
Jonathon Anderson
2023-03-18 22:34:05 -06:00
parent 6fc7c1e889
commit 132f14c4c3

View File

@@ -1,34 +1,34 @@
package batch
// package batch
import (
"testing"
"time"
// import (
// "testing"
// "time"
"github.com/stretchr/testify/assert"
)
// "github.com/stretchr/testify/assert"
// )
/* Submits 10 jobs into a pool that supports 2 simultaneous jobs, and
tests that only two of the jobs ran at a time by capturing the time
that they ran and comparing against the start time. */
func TestBatchPool (t *testing.T) {
pool := New(2)
var times []time.Time
for i := 0; i <= 10; i++ {
pool.Submit(func() {
times = append(times, time.Now())
time.Sleep(1 * time.Second)
})
}
startTime := time.Now()
pool.Run()
assert.Equal(t, 0 * time.Second, times[0].Sub(startTime).Round(time.Second))
assert.Equal(t, 0 * time.Second, times[1].Sub(startTime).Round(time.Second))
assert.Equal(t, 1 * time.Second, times[2].Sub(startTime).Round(time.Second))
assert.Equal(t, 1 * time.Second, times[3].Sub(startTime).Round(time.Second))
assert.Equal(t, 2 * time.Second, times[4].Sub(startTime).Round(time.Second))
assert.Equal(t, 2 * time.Second, times[5].Sub(startTime).Round(time.Second))
assert.Equal(t, 3 * time.Second, times[6].Sub(startTime).Round(time.Second))
assert.Equal(t, 3 * time.Second, times[7].Sub(startTime).Round(time.Second))
assert.Equal(t, 4 * time.Second, times[8].Sub(startTime).Round(time.Second))
assert.Equal(t, 4 * time.Second, times[9].Sub(startTime).Round(time.Second))
}
// /* Submits 10 jobs into a pool that supports 2 simultaneous jobs, and
// tests that only two of the jobs ran at a time by capturing the time
// that they ran and comparing against the start time. */
// func TestBatchPool (t *testing.T) {
// pool := New(2)
// var times []time.Time
// for i := 0; i <= 10; i++ {
// pool.Submit(func() {
// times = append(times, time.Now())
// time.Sleep(1 * time.Second)
// })
// }
// startTime := time.Now()
// pool.Run()
// assert.Equal(t, 0 * time.Second, times[0].Sub(startTime).Round(time.Second))
// assert.Equal(t, 0 * time.Second, times[1].Sub(startTime).Round(time.Second))
// assert.Equal(t, 1 * time.Second, times[2].Sub(startTime).Round(time.Second))
// assert.Equal(t, 1 * time.Second, times[3].Sub(startTime).Round(time.Second))
// assert.Equal(t, 2 * time.Second, times[4].Sub(startTime).Round(time.Second))
// assert.Equal(t, 2 * time.Second, times[5].Sub(startTime).Round(time.Second))
// assert.Equal(t, 3 * time.Second, times[6].Sub(startTime).Round(time.Second))
// assert.Equal(t, 3 * time.Second, times[7].Sub(startTime).Round(time.Second))
// assert.Equal(t, 4 * time.Second, times[8].Sub(startTime).Round(time.Second))
// assert.Equal(t, 4 * time.Second, times[9].Sub(startTime).Round(time.Second))
// }