Revert "(test): Run LogPollerWrapperTest v1/v2 tests sequentially"

This reverts commit 1ba2c06.
smartcontractkit · Feb 19, 2024 · 5388846 · 5388846
1 parent 99af29b
commit 5388846
Showing 1 changed file with 8 additions and 0 deletions.
diff --git 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}