core/services: more parallel tests

smartcontractkit · Dec 18, 2024 · 5eee570 · 5eee570
1 parent 2e3a707
commit 5eee570
Show file tree

Hide file tree

Showing 10 changed files with 25 additions and 0 deletions.
diff --git a/core/services/ocr2/plugins/llo/onchain_channel_definition_cache_integration_test.go b/core/services/ocr2/plugins/llo/onchain_channel_definition_cache_integration_test.go
@@ -83,6 +83,7 @@ func (m *MockReadCloser) Close() error {
 }
 
 func Test_ChannelDefinitionCache_Integration(t *testing.T) {
+	t.Parallel()
 	var (
 		invalidDefinitions    = []byte(`{{{`)
 		invalidDefinitionsSHA = sha3.Sum256(invalidDefinitions)

diff --git a/core/services/ocr2/plugins/ocr2keeper/integration_21_test.go b/core/services/ocr2/plugins/ocr2keeper/integration_21_test.go
@@ -59,6 +59,7 @@ import (
 )
 
 func TestFilterNamesFromSpec21(t *testing.T) {
+	t.Parallel()
 	b := make([]byte, 20)
 	_, err := crand.Read(b)
 	require.NoError(t, err)
@@ -85,6 +86,7 @@ func TestFilterNamesFromSpec21(t *testing.T) {
 }
 
 func TestIntegration_KeeperPluginConditionalUpkeep(t *testing.T) {
+	t.Parallel()
 	g := gomega.NewWithT(t)
 	lggr := logger.TestLogger(t)
 
@@ -182,6 +184,7 @@ func TestIntegration_KeeperPluginConditionalUpkeep(t *testing.T) {
 
 func TestIntegration_KeeperPluginLogUpkeep(t *testing.T) {
 	t.Skip("fails after geth upgrade https://github.com/smartcontractkit/chainlink/pull/11809; DEPENDENT ON SPECIFIC BLOCK PATTTERN?")
+	t.Parallel()
 	g := gomega.NewWithT(t)
 
 	// setup blockchain
@@ -275,6 +278,7 @@ func TestIntegration_KeeperPluginLogUpkeep(t *testing.T) {
 }
 
 func TestIntegration_KeeperPluginLogUpkeep_Retry(t *testing.T) {
+	t.Parallel()
 	g := gomega.NewWithT(t)
 
 	// setup blockchain
@@ -395,6 +399,7 @@ func TestIntegration_KeeperPluginLogUpkeep_Retry(t *testing.T) {
 }
 
 func TestIntegration_KeeperPluginLogUpkeep_ErrHandler(t *testing.T) {
+	t.Parallel()
 	g := gomega.NewWithT(t)
 
 	// setup blockchain

diff --git a/core/services/relay/evm/capabilities/workflows/syncer/workflow_syncer_test.go b/core/services/relay/evm/capabilities/workflows/syncer/workflow_syncer_test.go
@@ -92,6 +92,7 @@ func (m *testWorkflowRegistryContractLoader) LoadWorkflows(ctx context.Context,
 }
 
 func Test_EventHandlerStateSync(t *testing.T) {
+	t.Parallel()
 	lggr := logger.TestLogger(t)
 	backendTH := testutils.NewEVMBackendTH(t)
 	donID := uint32(1)
@@ -220,6 +221,7 @@ func Test_EventHandlerStateSync(t *testing.T) {
 }
 
 func Test_InitialStateSync(t *testing.T) {
+	t.Parallel()
 	lggr := logger.TestLogger(t)
 	backendTH := testutils.NewEVMBackendTH(t)
 	donID := uint32(1)
@@ -284,6 +286,7 @@ func Test_InitialStateSync(t *testing.T) {
 }
 
 func Test_SecretsWorker(t *testing.T) {
+	t.Parallel()
 	var (
 		ctx       = coretestutils.Context(t)
 		lggr      = logger.TestLogger(t)
@@ -384,6 +387,7 @@ func Test_SecretsWorker(t *testing.T) {
 }
 
 func Test_RegistrySyncer_WorkflowRegistered_InitiallyPaused(t *testing.T) {
+	t.Parallel()
 	var (
 		ctx       = coretestutils.Context(t)
 		lggr      = logger.TestLogger(t)
@@ -481,6 +485,7 @@ func (m *mockEngineFactory) new(ctx context.Context, wfid string, owner string,
 }
 
 func Test_RegistrySyncer_WorkflowRegistered_InitiallyActivated(t *testing.T) {
+	t.Parallel()
 	var (
 		ctx       = coretestutils.Context(t)
 		lggr      = logger.TestLogger(t)

diff --git a/core/services/relay/evm/functions/config_poller_test.go b/core/services/relay/evm/functions/config_poller_test.go
@@ -38,6 +38,7 @@ import (
 )
 
 func TestFunctionsConfigPoller(t *testing.T) {
+	t.Parallel()
 	t.Run("FunctionsPlugin", func(t *testing.T) {
 		runTest(t, functions.FunctionsPlugin, functions.FunctionsDigestPrefix)
 	})

diff --git a/core/services/relay/evm/mercury/config_digest_test.go b/core/services/relay/evm/mercury/config_digest_test.go
@@ -25,6 +25,7 @@ import (
 // Adapted from: https://github.com/smartcontractkit/offchain-reporting/blob/991ebe1462fd56826a1ddfb34287d542acb2baee/lib/offchainreporting2/chains/evmutil/config_digest_test.go
 
 func TestConfigCalculationMatches(t *testing.T) {
+	t.Parallel()
 	key, err := crypto.GenerateKey()
 	require.NoError(t, err, "could not make private key for EOA owner")
 	owner, err := bind.NewKeyedTransactorWithChainID(key, big.NewInt(1337))

diff --git a/core/services/relay/evm/mercury/config_poller_test.go b/core/services/relay/evm/mercury/config_poller_test.go
@@ -21,6 +21,7 @@ import (
 )
 
 func TestMercuryConfigPoller(t *testing.T) {
+	t.Parallel()
 	feedID := evmutils.NewHash()
 	feedIDBytes := [32]byte(feedID)
 

diff --git a/core/services/relay/evm/mercury/offchain_config_digester_test.go b/core/services/relay/evm/mercury/offchain_config_digester_test.go
@@ -12,6 +12,7 @@ import (
 )
 
 func Test_OffchainConfigDigester_ConfigDigest(t *testing.T) {
+	t.Parallel()
 	ctx := tests.Context(t)
 	// ChainID and ContractAddress are taken into account for computation
 	cd1, err := OffchainConfigDigester{ChainID: big.NewInt(0)}.ConfigDigest(ctx, types.ContractConfig{})

diff --git a/core/services/relay/evm/mercury/orm_test.go b/core/services/relay/evm/mercury/orm_test.go
@@ -20,6 +20,7 @@ var (
 )
 
 func TestORM(t *testing.T) {
+	t.Parallel()
 	ctx := testutils.Context(t)
 	db := pgtest.NewSqlxDB(t)
 
@@ -151,6 +152,7 @@ func TestORM(t *testing.T) {
 }
 
 func TestORM_InsertTransmitRequest_MultipleServerURLs(t *testing.T) {
+	t.Parallel()
 	ctx := testutils.Context(t)
 	db := pgtest.NewSqlxDB(t)
 
@@ -196,6 +198,7 @@ func TestORM_InsertTransmitRequest_MultipleServerURLs(t *testing.T) {
 }
 
 func TestORM_PruneTransmitRequests(t *testing.T) {
+	t.Parallel()
 	ctx := testutils.Context(t)
 	db := pgtest.NewSqlxDB(t)
 	jobID := rand.Int32() // foreign key constraints disabled so value doesn't matter
@@ -289,6 +292,7 @@ func TestORM_PruneTransmitRequests(t *testing.T) {
 }
 
 func TestORM_InsertTransmitRequest_LatestReport(t *testing.T) {
+	t.Parallel()
 	ctx := testutils.Context(t)
 	db := pgtest.NewSqlxDB(t)
 	jobID := rand.Int32() // foreign key constraints disabled so value doesn't matter

diff --git a/core/services/relay/evm/mercury/persistence_manager_test.go b/core/services/relay/evm/mercury/persistence_manager_test.go
@@ -27,6 +27,7 @@ func bootstrapPersistenceManager(t *testing.T, jobID int32, db *sqlx.DB) (*Persi
 }
 
 func TestPersistenceManager(t *testing.T) {
+	t.Parallel()
 	jobID1 := rand.Int32()
 	jobID2 := jobID1 + 1
 
@@ -69,6 +70,7 @@ func TestPersistenceManager(t *testing.T) {
 }
 
 func TestPersistenceManagerAsyncDelete(t *testing.T) {
+	t.Parallel()
 	ctx := testutils.Context(t)
 	jobID := rand.Int32()
 	db := pgtest.NewSqlxDB(t)
@@ -114,6 +116,7 @@ func TestPersistenceManagerAsyncDelete(t *testing.T) {
 }
 
 func TestPersistenceManagerPrune(t *testing.T) {
+	t.Parallel()
 	jobID1 := rand.Int32()
 	jobID2 := jobID1 + 1
 	db := pgtest.NewSqlxDB(t)

diff --git a/core/services/relay/evm/mercury/transmitter_test.go b/core/services/relay/evm/mercury/transmitter_test.go
@@ -37,6 +37,7 @@ func (m mockCfg) TransmitTimeout() commonconfig.Duration {
 }
 
 func Test_MercuryTransmitter_Transmit(t *testing.T) {
+	t.Parallel()
 	lggr := logger.TestLogger(t)
 	db := pgtest.NewSqlxDB(t)
 	var jobID int32
@@ -403,6 +404,7 @@ func Test_MercuryTransmitter_FetchInitialMaxFinalizedBlockNumber(t *testing.T) {
 }
 
 func Test_sortReportsLatestFirst(t *testing.T) {
+	t.Parallel()
 	reports := []*pb.Report{
 		nil,
 		{ObservationsTimestamp: 1},
@@ -457,6 +459,7 @@ func (m *mockQ) Init(transmissions []*Transmission) {}
 func (m *mockQ) IsEmpty() bool                      { return false }
 
 func Test_MercuryTransmitter_runQueueLoop(t *testing.T) {
+	t.Parallel()
 	feedIDHex := utils.NewHash().Hex()
 	lggr := logger.TestLogger(t)
 	c := &mocks.MockWSRPCClient{}