diff --git a/core/capabilities/ccip/ccip_integration_tests/usdcreader/usdcreader_test.go b/core/capabilities/ccip/ccip_integration_tests/usdcreader/usdcreader_test.go index 1699820da8b..8d26d2b395a 100644 --- a/core/capabilities/ccip/ccip_integration_tests/usdcreader/usdcreader_test.go +++ b/core/capabilities/ccip/ccip_integration_tests/usdcreader/usdcreader_test.go @@ -85,6 +85,10 @@ func Test_USDCReader_MessageHashes(t *testing.T) { emitMessageSent(t, ts, ethereumDomainCCTP, polygonDomainCCTP, 31) emitMessageSent(t, ts, ethereumDomainCCTP, polygonDomainCCTP, 41) + // Need to replay as sometimes the logs are not picked up by the log poller (?) + // Maybe another situation where chain reader doesn't register filters as expected. + require.NoError(t, ts.lp.Replay(ctx, 1)) + tt := []struct { name string tokens map[exectypes.MessageTokenID]cciptypes.RampTokenAmount @@ -198,7 +202,7 @@ func Test_USDCReader_MessageHashes(t *testing.T) { } } return true - }, tests.WaitTimeout(t), 100*time.Millisecond) + }, tests.WaitTimeout(t), 50*time.Millisecond) }) } } @@ -286,6 +290,7 @@ func testSetup(ctx context.Context, t *testing.T, readerChain cciptypes.ChainSel auth: auth, cl: cl, reader: cr, + lp: lp, } } @@ -296,4 +301,5 @@ type testSetupData struct { auth *bind.TransactOpts cl client.Client reader types.ContractReader + lp logpoller.LogPoller }