diff --git a/modules/queue/queue_disk_test.go b/modules/queue/queue_disk_test.go index edaed49a52396..6e7127ab2de30 100644 --- a/modules/queue/queue_disk_test.go +++ b/modules/queue/queue_disk_test.go @@ -40,7 +40,7 @@ func TestLevelQueue(t *testing.T) { BatchLength: 2, BlockTimeout: 1 * time.Second, BoostTimeout: 5 * time.Minute, - BoostWorkers: 5, + BoostWorkers: 0, MaxWorkers: 10, }, Workers: 1, @@ -70,10 +70,11 @@ func TestLevelQueue(t *testing.T) { }() result1 := <-handleChan + result2 := <-handleChan + assert.Equal(t, test1.TestString, result1.TestString) assert.Equal(t, test1.TestInt, result1.TestInt) - result2 := <-handleChan assert.Equal(t, test2.TestString, result2.TestString) assert.Equal(t, test2.TestInt, result2.TestInt) @@ -113,7 +114,7 @@ func TestLevelQueue(t *testing.T) { BatchLength: 2, BlockTimeout: 1 * time.Second, BoostTimeout: 5 * time.Minute, - BoostWorkers: 5, + BoostWorkers: 0, MaxWorkers: 10, }, Workers: 1, @@ -134,10 +135,11 @@ func TestLevelQueue(t *testing.T) { }) result3 := <-handleChan + result4 := <-handleChan + assert.Equal(t, test1.TestString, result3.TestString) assert.Equal(t, test1.TestInt, result3.TestInt) - result4 := <-handleChan assert.Equal(t, test2.TestString, result4.TestString) assert.Equal(t, test2.TestInt, result4.TestInt)