Merge pull request #878 from onflow/bastian/parallelize-tests

Parallelize tests

Author: turbolent

adapters/access_test.go

@@ -54,6 +54,8 @@ func accessTest(f func(t *testing.T, adapter *AccessAdapter, emu *mocks.MockEmul
 
 func TestAccess(t *testing.T) {
 
+	t.Parallel()
+
 	t.Run("Ping", accessTest(func(t *testing.T, adapter *AccessAdapter, emu *mocks.MockEmulator) {
 		emu.EXPECT().
 			Ping().

adapters/sdk_test.go

@@ -55,6 +55,8 @@ func sdkTest(f func(t *testing.T, adapter *SDKAdapter, emu *mocks.MockEmulator))
 
 func TestSDK(t *testing.T) {
 
+	t.Parallel()
+
 	t.Run("Ping", sdkTest(func(t *testing.T, adapter *SDKAdapter, emu *mocks.MockEmulator) {
 		emu.EXPECT().
 			Ping().

emulator/script_test.go

@@ -252,6 +252,8 @@ func TestScriptExecutionLimit(t *testing.T) {
 // within a script
 func TestScriptWithCadenceRandom(t *testing.T) {
 
+	t.Parallel()
+
 	//language=cadence
 	code := `
       access(all)
@@ -273,6 +275,9 @@ func TestScriptWithCadenceRandom(t *testing.T) {
 
 // TestEVM checks evm functionality
 func TestEVM(t *testing.T) {
+
+	t.Parallel()
+
 	serviceAddr := flowgo.Emulator.Chain().ServiceAddress()
 	code := []byte(fmt.Sprintf(
 		`

emulator/transaction_test.go

@@ -2161,6 +2161,9 @@ func TestRollbackTransaction(t *testing.T) {
 // TestTransactionWithCadenceRandom checks Cadence's random function works
 // within a transaction
 func TestTransactionWithCadenceRandom(t *testing.T) {
+
+	t.Parallel()
+
 	b, adapter := setupTransactionTests(t)
 
 	code := `

server/server_test.go

@@ -35,6 +35,8 @@ import (
 )
 
 func TestNoPersistence(t *testing.T) {
+	t.Parallel()
+
 	logger := zerolog.Nop()
 
 	dbPath := "test_no_persistence"
@@ -54,6 +56,8 @@ func TestNoPersistence(t *testing.T) {
 }
 
 func TestPersistenceWithPersistFlag(t *testing.T) {
+	t.Parallel()
+
 	logger := zerolog.Nop()
 
 	dbPath := "test_persistence"
@@ -73,6 +77,8 @@ func TestPersistenceWithPersistFlag(t *testing.T) {
 }
 
 func TestPersistenceWithSnapshotFlag(t *testing.T) {
+	t.Parallel()
+
 	logger := zerolog.Nop()
 
 	dbPath := "test_persistence_with_snapshot"
@@ -92,6 +98,7 @@ func TestPersistenceWithSnapshotFlag(t *testing.T) {
 }
 
 func TestExecuteScript(t *testing.T) {
+	t.Parallel()
 
 	logger := zerolog.Nop()
 	server := NewEmulatorServer(&logger, &Config{})
@@ -114,6 +121,8 @@ func TestExecuteScript(t *testing.T) {
 }
 
 func TestExecuteScriptImportingContracts(t *testing.T) {
+	t.Parallel()
+
 	conf := &Config{
 		WithContracts: true,
 	}
@@ -144,6 +153,7 @@ func TestExecuteScriptImportingContracts(t *testing.T) {
 }
 
 func TestCustomChainID(t *testing.T) {
+	t.Parallel()
 
 	conf := &Config{
 		WithContracts: true,
@@ -159,6 +169,8 @@ func TestCustomChainID(t *testing.T) {
 }
 
 func TestScheduledCallback_IncrementsCounter(t *testing.T) {
+	t.Parallel()
+
 	logger := zerolog.Nop()
 	conf := &Config{
 		WithContracts:                true,

storage/checkpoint/checkpoint_test.go

@@ -51,6 +51,8 @@ import (
 
 func Test_Checkpoint_Storage(t *testing.T) {
 
+	t.Parallel()
+
 	dir := t.TempDir()
 
 	chainID := flowsdk.Emulator

storage/store_test.go

@@ -192,6 +192,7 @@ func TestTransactions(t *testing.T) {
 
 func TestFullCollection(t *testing.T) {
 	t.Parallel()
+
 	store, dir := setupStore(t)
 	defer func() {
 		require.NoError(t, store.Close())