adjust eventually usages (#13556)

smartcontractkit · Jun 17, 2024 · c0f0c38 · c0f0c38
1 parent ba9b0cc
commit c0f0c38
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 4 deletions.
diff --git a/common/client/poller_test.go b/common/client/poller_test.go
@@ -13,6 +13,7 @@ import (
 	"go.uber.org/zap"
 
 	"github.com/smartcontractkit/chainlink-common/pkg/logger"
+	"github.com/smartcontractkit/chainlink-common/pkg/utils/tests"
 )
 
 func Test_Poller(t *testing.T) {
@@ -89,7 +90,7 @@ func Test_Poller(t *testing.T) {
 			}
 			return true
 		}
-		require.Eventually(t, logsSeen, time.Second, time.Millisecond)
+		require.Eventually(t, logsSeen, tests.WaitTimeout(t), 100*time.Millisecond)
 	})
 
 	t.Run("Test polling timeout", func(t *testing.T) {
@@ -114,7 +115,7 @@ func Test_Poller(t *testing.T) {
 		logsSeen := func() bool {
 			return observedLogs.FilterMessage("polling error: context deadline exceeded").Len() >= 1
 		}
-		require.Eventually(t, logsSeen, time.Second, time.Millisecond)
+		require.Eventually(t, logsSeen, tests.WaitTimeout(t), 100*time.Millisecond)
 	})
 
 	t.Run("Test unsubscribe during polling", func(t *testing.T) {
@@ -145,7 +146,7 @@ func Test_Poller(t *testing.T) {
 		logsSeen := func() bool {
 			return observedLogs.FilterMessage("polling error: context canceled").Len() >= 1
 		}
-		require.Eventually(t, logsSeen, time.Second, time.Millisecond)
+		require.Eventually(t, logsSeen, tests.WaitTimeout(t), 100*time.Millisecond)
 	})
 }
 

diff --git a/core/services/relay/evm/evmtesting/run_tests.go b/core/services/relay/evm/evmtesting/run_tests.go
@@ -39,7 +39,7 @@ func RunChainReaderEvmTests[T TestingT[T]](t T, it *EVMChainReaderInterfaceTeste
 
 		require.Eventually(t, func() bool {
 			return cr.GetLatestValue(ctx, AnyContractName, triggerWithDynamicTopic, input, output) == nil
-		}, it.MaxWaitTimeForEvents(), time.Millisecond*10)
+		}, it.MaxWaitTimeForEvents(), 100*time.Millisecond)
 
 		assert.Equal(t, &anyString, rOutput.FieldByName("Field").Interface())
 		topic, err := abi.MakeTopics([]any{anyString})