parallelize tests

Author: turbolent

fvm/accounts_test.go

@@ -360,6 +360,8 @@ func newAccountKey(
 
 func TestCreateAccount(t *testing.T) {
 
+	t.Parallel()
+
 	options := []fvm.Option{
 		fvm.WithAuthorizationChecksEnabled(false),
 		fvm.WithSequenceNumberCheckAndIncrementEnabled(false),
@@ -469,6 +471,8 @@ func TestCreateAccount(t *testing.T) {
 
 func TestCreateAccount_WithRestrictedAccountCreation(t *testing.T) {
 
+	t.Parallel()
+
 	options := []fvm.Option{
 		fvm.WithAuthorizationChecksEnabled(false),
 		fvm.WithSequenceNumberCheckAndIncrementEnabled(false),
@@ -614,6 +618,8 @@ func TestCreateAccount_WithRestrictedAccountCreation(t *testing.T) {
 
 func TestAddAccountKey(t *testing.T) {
 
+	t.Parallel()
+
 	options := []fvm.Option{
 		fvm.WithAuthorizationChecksEnabled(false),
 		fvm.WithSequenceNumberCheckAndIncrementEnabled(false),
@@ -932,6 +938,8 @@ func TestAddAccountKey(t *testing.T) {
 
 func TestRemoveAccountKey(t *testing.T) {
 
+	t.Parallel()
+
 	options := []fvm.Option{
 		fvm.WithAuthorizationChecksEnabled(false),
 		fvm.WithSequenceNumberCheckAndIncrementEnabled(false),
@@ -1211,6 +1219,8 @@ func TestRemoveAccountKey(t *testing.T) {
 
 func TestGetAccountKey(t *testing.T) {
 
+	t.Parallel()
+
 	options := []fvm.Option{
 		fvm.WithAuthorizationChecksEnabled(false),
 		fvm.WithSequenceNumberCheckAndIncrementEnabled(false),
@@ -1483,6 +1493,9 @@ func byteSliceToCadenceArrayLiteral(bytes []byte) string {
 }
 
 func TestAccountBalanceFields(t *testing.T) {
+
+	t.Parallel()
+
 	t.Run("Get balance works",
 		newVMTest().withContextOptions(
 			fvm.WithAuthorizationChecksEnabled(false),
@@ -1725,6 +1738,9 @@ func TestAccountBalanceFields(t *testing.T) {
 }
 
 func TestGetStorageCapacity(t *testing.T) {
+
+	t.Parallel()
+
 	t.Run("Get storage capacity",
 		newVMTest().withContextOptions(
 			fvm.WithAuthorizationChecksEnabled(false),

fvm/environment/programs_test.go

@@ -147,6 +147,8 @@ func getTestContract(
 }
 
 func Test_Programs(t *testing.T) {
+	t.Parallel()
+
 	vm := fvm.NewVirtualMachine()
 	derivedBlockData := derived.NewEmptyDerivedBlockData(0)
 

fvm/fvm_blockcontext_test.go

@@ -1751,6 +1751,8 @@ func TestBlockContext_GetAccount(t *testing.T) {
 }
 
 func TestBlockContext_Random(t *testing.T) {
+	t.Parallel()
+
 	chain, vm := createChainAndVm(flow.Mainnet)
 	header := &flow.Header{HeaderBody: flow.HeaderBody{Height: 42}}
 	source := testutil.EntropyProviderFixture(nil)
@@ -1906,6 +1908,8 @@ func TestBlockContext_ExecuteTransaction_CreateAccount_WithMonotonicAddresses(t
 }
 
 func TestBlockContext_ExecuteTransaction_FailingTransactions(t *testing.T) {
+	t.Parallel()
+
 	getBalance := func(
 		vm fvm.VM,
 		chain flow.Chain,

fvm/fvm_test.go

@@ -474,6 +474,8 @@ func TestWithServiceAccount(t *testing.T) {
 }
 
 func TestEventLimits(t *testing.T) {
+	t.Parallel()
+
 	chain, vm := createChainAndVm(flow.Mainnet)
 
 	ctx := fvm.NewContext(
@@ -579,6 +581,7 @@ func TestEventLimits(t *testing.T) {
 // TestHappyPathSigning checks that a signing a transaction with `Sign` doesn't produce an error.
 // Transaction verification tests are in `TestVerifySignatureFromTransaction`.
 func TestHappyPathTransactionSigning(t *testing.T) {
+	t.Parallel()
 
 	newVMTest().run(
 		func(t *testing.T, vm fvm.VM, chain flow.Chain, ctx fvm.Context, snapshotTree snapshot.SnapshotTree) {
@@ -620,6 +623,8 @@ func TestHappyPathTransactionSigning(t *testing.T) {
 }
 
 func TestTransactionFeeDeduction(t *testing.T) {
+	t.Parallel()
+
 	getBalance := func(vm fvm.VM, chain flow.Chain, ctx fvm.Context, snapshotTree snapshot.SnapshotTree, address flow.Address) uint64 {
 		sc := systemcontracts.SystemContractsForChain(chain.ChainID())
 		code := []byte(fmt.Sprintf(
@@ -1098,6 +1103,7 @@ func TestTransactionFeeDeduction(t *testing.T) {
 }
 
 func TestSettingExecutionWeights(t *testing.T) {
+	t.Parallel()
 
 	// change the chain so that the metering settings are read from the service account
 	chain := flow.Emulator.Chain()
@@ -1837,6 +1843,8 @@ func TestEnforcingComputationLimit(t *testing.T) {
 }
 
 func TestStorageCapacity(t *testing.T) {
+	t.Parallel()
+
 	t.Run("Storage capacity updates on FLOW transfer", newVMTest().
 		withContextOptions(
 			fvm.WithAuthorizationChecksEnabled(false),
@@ -2328,6 +2336,9 @@ func TestScriptExecutionLimit(t *testing.T) {
 }
 
 func TestInteractionLimit(t *testing.T) {
+
+	t.Parallel()
+
 	type testCase struct {
 		name             string
 		interactionLimit uint64
@@ -2497,6 +2508,7 @@ func TestInteractionLimit(t *testing.T) {
 }
 
 func TestAttachments(t *testing.T) {
+	t.Parallel()
 
 	newVMTest().
 		withBootstrapProcedureOptions().
@@ -2531,6 +2543,8 @@ func TestAttachments(t *testing.T) {
 }
 
 func TestCapabilityControllers(t *testing.T) {
+	t.Parallel()
+
 	test := func(t *testing.T) {
 		newVMTest().
 			withBootstrapProcedureOptions().
@@ -2800,6 +2814,8 @@ func TestStorageIterationWithBrokenValues(t *testing.T) {
 }
 
 func TestEntropyCallOnlyOkIfAllowed(t *testing.T) {
+	t.Parallel()
+
 	source := testutil.EntropyProviderFixture(nil)
 
 	test := func(t *testing.T, allowed bool) {
@@ -2859,6 +2875,8 @@ func TestEntropyCallOnlyOkIfAllowed(t *testing.T) {
 }
 
 func TestEntropyCallExpectsNoParameters(t *testing.T) {
+	t.Parallel()
+
 	source := testutil.EntropyProviderFixture(nil)
 	newVMTest().
 		withBootstrapProcedureOptions().
@@ -2902,6 +2920,7 @@ func TestEntropyCallExpectsNoParameters(t *testing.T) {
 }
 
 func TestTransientNetworkCoreContractAddresses(t *testing.T) {
+	t.Parallel()
 
 	// This test ensures that the transient networks have the correct core contract addresses.
 	newVMTest().
@@ -2927,6 +2946,8 @@ func TestTransientNetworkCoreContractAddresses(t *testing.T) {
 }
 
 func TestFlowCallbackScheduler(t *testing.T) {
+	t.Parallel()
+
 	ctxOpts := []fvm.Option{
 		fvm.WithScheduleCallbacksEnabled(true),
 	}
@@ -2975,6 +2996,8 @@ func TestFlowCallbackScheduler(t *testing.T) {
 }
 
 func TestEVM(t *testing.T) {
+	t.Parallel()
+
 	blocks := new(envMock.Blocks)
 	block1 := unittest.BlockFixture()
 	blocks.On("ByHeightFrom",
@@ -3244,6 +3267,8 @@ func TestEVM(t *testing.T) {
 }
 
 func TestVMBridge(t *testing.T) {
+	t.Parallel()
+
 	blocks := new(envMock.Blocks)
 	block1 := unittest.BlockFixture()
 	blocks.On("ByHeightFrom",
@@ -3812,6 +3837,7 @@ func TestVMBridge(t *testing.T) {
 }
 
 func TestAccountCapabilitiesGetEntitledRejection(t *testing.T) {
+	t.Parallel()
 
 	// Note: This cannot be tested anymore using a transaction,
 	// because publish method also aborts when trying to publish an entitled capability.
@@ -3874,6 +3900,7 @@ func TestAccountCapabilitiesGetEntitledRejection(t *testing.T) {
 }
 
 func TestAccountCapabilitiesPublishEntitledRejection(t *testing.T) {
+	t.Parallel()
 
 	t.Run("entitled capability", newVMTest().
 		run(func(
@@ -4131,6 +4158,7 @@ func TestCrypto(t *testing.T) {
 }
 
 func Test_BlockHashListShouldWriteOnPush(t *testing.T) {
+	t.Parallel()
 
 	chain := flow.Emulator.Chain()
 	sc := systemcontracts.SystemContractsForChain(chain.ChainID())

fvm/transactionVerifier_test.go

@@ -17,6 +17,8 @@ import (
 )
 
 func TestTransactionVerification(t *testing.T) {
+	t.Parallel()
+
 	txnState := testutils.NewSimpleTransaction(nil)
 	accounts := environment.NewAccounts(txnState)