From f2082fc387b6463853e4fb60fd1aba6871b729a0 Mon Sep 17 00:00:00 2001 From: Blake Rouse Date: Tue, 16 Jan 2024 15:25:30 -0500 Subject: [PATCH] Fix unit test on Windows. --- pkg/component/runtime/manager_test.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/pkg/component/runtime/manager_test.go b/pkg/component/runtime/manager_test.go index 076e0c55ae0..3c27889aabb 100644 --- a/pkg/component/runtime/manager_test.go +++ b/pkg/component/runtime/manager_test.go @@ -3504,7 +3504,7 @@ func TestManager_FakeInput_Chunk(t *testing.T) { }() // build the units to ensure that there is more than double the units required for the GRPC configuration - minimumMsgSize := grpcConfig.MaxMsgSize * 2 // double it + minimumMsgSize := int(float64(grpcConfig.MaxMsgSize) * 1.2) // increase by 20% var units []component.Unit var unitsSize int var nextUnitID int @@ -3609,13 +3609,13 @@ func TestManager_FakeInput_Chunk(t *testing.T) { err = <-m.errCh require.NoError(t, err) - endTimer := time.NewTimer(3 * time.Minute) // very large number of units will take time + endTimer := time.NewTimer(6 * time.Minute) // very large number of units will take time defer endTimer.Stop() LOOP: for { select { case <-endTimer.C: - t.Fatalf("timed out after 3 minutes") + t.Fatalf("timed out after 6 minutes") case err := <-errCh: require.NoError(t, err) case err := <-subErrCh: