parallelize tests

Author: turbolent

engine/execution/block_result_test.go

@@ -26,6 +26,8 @@ func makeBlockExecutionResultFixture(serviceEventsPerChunk []int) *BlockExecutio
 
 // Tests that ServiceEventCountForChunk method works as expected under various circumstances:
 func TestBlockExecutionResult_ServiceEventCountForChunk(t *testing.T) {
+	t.Parallel()
+
 	t.Run("no service events", func(t *testing.T) {
 		nChunks := rand.Intn(10) + 1 // always contains at least system chunk
 		blockResult := makeBlockExecutionResultFixture(make([]int, nChunks))

engine/execution/computation/execution_verification_test.go

@@ -56,6 +56,9 @@ var chain = flow.Emulator.Chain()
 // This is not relevant to the test, as only the non-system transactions are tested.
 
 func Test_ExecutionMatchesVerification(t *testing.T) {
+
+	t.Parallel()
+
 	t.Run("empty block", func(t *testing.T) {
 		executeBlockAndVerify(t,
 			[][]*flow.TransactionBody{},
@@ -339,6 +342,7 @@ func Test_ExecutionMatchesVerification(t *testing.T) {
 }
 
 func TestTransactionFeeDeduction(t *testing.T) {
+	t.Parallel()
 
 	type testCase struct {
 		name          string

engine/execution/computation/manager_test.go

@@ -51,6 +51,8 @@ import (
 var scriptLogThreshold = 1 * time.Second
 
 func TestComputeBlockWithStorage(t *testing.T) {
+	t.Parallel()
+
 	chain := flow.Mainnet.Chain()
 
 	vm := fvm.NewVirtualMachine()
@@ -180,6 +182,7 @@ func TestComputeBlockWithStorage(t *testing.T) {
 }
 
 func TestComputeBlock_Uploader(t *testing.T) {
+	t.Parallel()
 
 	noopCollector := &metrics.NoopCollector{}
 
@@ -230,6 +233,7 @@ func TestComputeBlock_Uploader(t *testing.T) {
 }
 
 func TestExecuteScript(t *testing.T) {
+	t.Parallel()
 
 	logger := zerolog.Nop()
 
@@ -296,6 +300,7 @@ func TestExecuteScript(t *testing.T) {
 // Balance script used to swallow errors, which meant that even if the view was empty, a script that did nothing but get
 // the balance of an account would succeed and return 0.
 func TestExecuteScript_BalanceScriptFailsIfViewIsEmpty(t *testing.T) {
+	t.Parallel()
 
 	logger := zerolog.Nop()
 
@@ -361,6 +366,7 @@ func TestExecuteScript_BalanceScriptFailsIfViewIsEmpty(t *testing.T) {
 }
 
 func TestExecuteScripPanicsAreHandled(t *testing.T) {
+	t.Parallel()
 
 	ctx := fvm.NewContext()
 
@@ -411,6 +417,7 @@ func TestExecuteScripPanicsAreHandled(t *testing.T) {
 }
 
 func TestExecuteScript_LongScriptsAreLogged(t *testing.T) {
+	t.Parallel()
 
 	ctx := fvm.NewContext()
 
@@ -464,6 +471,7 @@ func TestExecuteScript_LongScriptsAreLogged(t *testing.T) {
 }
 
 func TestExecuteScript_ShortScriptsAreNotLogged(t *testing.T) {
+	t.Parallel()
 
 	ctx := fvm.NewContext()
 
@@ -647,6 +655,7 @@ func (f *FakeBlockComputer) ExecuteBlock(
 }
 
 func TestExecuteScriptTimeout(t *testing.T) {
+	t.Parallel()
 
 	timeout := 1 * time.Millisecond
 	manager, err := New(
@@ -694,6 +703,7 @@ func TestExecuteScriptTimeout(t *testing.T) {
 }
 
 func TestExecuteScriptCancelled(t *testing.T) {
+	t.Parallel()
 
 	timeout := 30 * time.Second
 	manager, err := New(
@@ -750,6 +760,7 @@ func TestExecuteScriptCancelled(t *testing.T) {
 }
 
 func Test_EventEncodingFailsOnlyTxAndCarriesOn(t *testing.T) {
+	t.Parallel()
 
 	chain := flow.Mainnet.Chain()
 	vm := fvm.NewVirtualMachine()
@@ -908,6 +919,7 @@ func (e *testingEventEncoder) Encode(event cadence.Event) ([]byte, error) {
 }
 
 func TestScriptStorageMutationsDiscarded(t *testing.T) {
+	t.Parallel()
 
 	timeout := 10 * time.Second
 	chain := flow.Mainnet.Chain()

engine/execution/computation/programs_test.go

@@ -40,6 +40,8 @@ const (
 )
 
 func TestPrograms_TestContractUpdates(t *testing.T) {
+	t.Parallel()
+
 	chain := flow.Mainnet.Chain()
 	vm := fvm.NewVirtualMachine()
 	execCtx := fvm.NewContext(fvm.WithChain(chain))
@@ -215,6 +217,8 @@ func (b blockProvider) ByHeightFrom(height uint64, _ *flow.Header) (*flow.Header
 //	        -> Block121 (emit event - version should be 2)
 //	            -> Block1211 (emit event - version should be 2)
 func TestPrograms_TestBlockForks(t *testing.T) {
+	t.Parallel()
+
 	block := unittest.BlockFixture()
 	chain := flow.Emulator.Chain()
 	vm := fvm.NewVirtualMachine()

engine/execution/execution_test.go

@@ -38,6 +38,8 @@ func sendBlock(exeNode *testmock.ExecutionNode, from flow.Identifier, proposal *
 // create another child block which will trigger the parent
 // block to be incorporated and be passed to the ingestion engine
 func TestExecutionFlow(t *testing.T) {
+	t.Parallel()
+
 	hub := stub.NewNetworkHub()
 
 	chainID := flow.Testnet
@@ -383,6 +385,8 @@ func makeSuccessBlock(t *testing.T, conID *flow.Identity, colID *flow.Identity,
 // Test a successful tx should change the statecommitment,
 // but a failed Tx should not change the statecommitment.
 func TestFailedTxWillNotChangeStateCommitment(t *testing.T) {
+	t.Parallel()
+
 	hub := stub.NewNetworkHub()
 
 	chainID := flow.Emulator
@@ -547,6 +551,8 @@ func mockCollectionEngineToReturnCollections(t *testing.T, collectionNode *testm
 
 // Test the receipt will be sent to multiple verification nodes
 func TestBroadcastToMultipleVerificationNodes(t *testing.T) {
+	t.Parallel()
+
 	hub := stub.NewNetworkHub()
 
 	chainID := flow.Emulator