diff --git a/core/services/relay/evm/functions/logpoller_wrapper_test.go b/core/services/relay/evm/functions/logpoller_wrapper_test.go index 60dc0e03ffe..ef3cba72a09 100644 --- a/core/services/relay/evm/functions/logpoller_wrapper_test.go +++ b/core/services/relay/evm/functions/logpoller_wrapper_test.go @@ -125,6 +125,7 @@ func getMockedRequestLogV2(t *testing.T) logpoller.Log { } func TestLogPollerWrapper_SingleSubscriberEmptyEvents_CoordinatorV1(t *testing.T) { + t.Parallel() lp, lpWrapper, client := setUp(t, 100_000) // check only once lp.On("LatestBlock").Return(logpoller.LogPollerBlock{BlockNumber: int64(100)}, nil) @@ -156,6 +157,7 @@ func TestLogPollerWrapper_SingleSubscriberEmptyEvents_CoordinatorV1(t *testing.T } func TestLogPollerWrapper_SingleSubscriberEmptyEvents_CoordinatorV2(t *testing.T) { + t.Parallel() lp, lpWrapper, client := setUp(t, 100_000) // check only once lp.On("LatestBlock").Return(logpoller.LogPollerBlock{BlockNumber: int64(100)}, nil) @@ -187,6 +189,7 @@ func TestLogPollerWrapper_SingleSubscriberEmptyEvents_CoordinatorV2(t *testing.T } func TestLogPollerWrapper_ErrorOnZeroAddresses(t *testing.T) { + t.Parallel() lp, lpWrapper, client := setUp(t, 100_000) // check only once lp.On("LatestBlock").Return(logpoller.LogPollerBlock{BlockNumber: int64(100)}, nil) @@ -198,6 +201,7 @@ func TestLogPollerWrapper_ErrorOnZeroAddresses(t *testing.T) { } func TestLogPollerWrapper_LatestEvents_ReorgHandlingV1(t *testing.T) { + t.Parallel() lp, lpWrapper, client := setUp(t, 100_000) lp.On("LatestBlock").Return(logpoller.LogPollerBlock{BlockNumber: int64(100)}, nil) client.On("CallContract", mock.Anything, ethereum.CallMsg{ // getContractById @@ -243,6 +247,7 @@ func TestLogPollerWrapper_LatestEvents_ReorgHandlingV1(t *testing.T) { } func TestLogPollerWrapper_LatestEvents_ReorgHandlingV2(t *testing.T) { + t.Parallel() lp, lpWrapper, client := setUp(t, 100_000) lp.On("LatestBlock").Return(logpoller.LogPollerBlock{BlockNumber: int64(100)}, nil) client.On("CallContract", mock.Anything, ethereum.CallMsg{ // getContractById @@ -288,6 +293,7 @@ func TestLogPollerWrapper_LatestEvents_ReorgHandlingV2(t *testing.T) { } func TestLogPollerWrapper_FilterPreviouslyDetectedEvents_TruncatesLogs(t *testing.T) { + t.Parallel() _, lpWrapper, _ := setUp(t, 100_000) inputLogs := make([]logpoller.Log, maxLogsToProcess+100) @@ -305,6 +311,7 @@ func TestLogPollerWrapper_FilterPreviouslyDetectedEvents_TruncatesLogs(t *testin } func TestLogPollerWrapper_FilterPreviouslyDetectedEvents_SkipsInvalidLog(t *testing.T) { + t.Parallel() _, lpWrapper, _ := setUp(t, 100_000) inputLogs := []logpoller.Log{getMockedRequestLogV1(t)} inputLogs[0].Topics = [][]byte{[]byte("invalid topic")} @@ -319,6 +326,7 @@ func TestLogPollerWrapper_FilterPreviouslyDetectedEvents_SkipsInvalidLog(t *test } func TestLogPollerWrapper_FilterPreviouslyDetectedEvents_FiltersPreviouslyDetectedEvent(t *testing.T) { + t.Parallel() _, lpWrapper, _ := setUp(t, 100_000) mockedRequestLog := getMockedRequestLogV1(t) inputLogs := []logpoller.Log{mockedRequestLog}