From 4582a1f59e1d0aa0ef430df0f7cdaaf70aeb02df Mon Sep 17 00:00:00 2001 From: Christian Goll Date: Fri, 24 Mar 2023 09:52:38 +0100 Subject: [PATCH] fix linting for disabled batch test Signed-off-by: Christian Goll --- internal/pkg/batch/batch_test.go | 64 ++++++++++++++++---------------- 1 file changed, 33 insertions(+), 31 deletions(-) diff --git a/internal/pkg/batch/batch_test.go b/internal/pkg/batch/batch_test.go index c9276706..98a4ce01 100644 --- a/internal/pkg/batch/batch_test.go +++ b/internal/pkg/batch/batch_test.go @@ -1,34 +1,36 @@ -// package batch +package batch -// import ( -// "testing" -// "time" +import ( + "testing" +) -// "github.com/stretchr/testify/assert" -// ) +/* +Submits 10 jobs into a pool that supports 2 simultaneous jobs, and -// /* 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)) -// } + 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)) + */ +}