Added t.Parallel() to acceptance tests (#1427)

nfx · web-flow · commit c6c5a88a5645 · 2022-07-06T17:33:35.000+02:00
diff --git a/access/acceptance/sql_permissions_test.go b/access/acceptance/sql_permissions_test.go
@@ -20,7 +20,7 @@ func TestAccTableACL(t *testing.T) {
 	if cloudEnv == "" {
 		t.Skip("Acceptance tests skipped unless env 'CLOUD_ENV' is set")
 	}
-
+	t.Parallel()
 	client := common.CommonEnvironmentClient()
 	client.WithCommandExecutor(func(ctx context.Context,
 		dc *common.DatabricksClient) common.CommandExecutor {
diff --git a/access/resource_ip_access_list_test.go b/access/resource_ip_access_list_test.go
@@ -30,6 +30,7 @@ func TestAccIPACL(t *testing.T) {
 	if cloud == "" {
 		t.Skip("Acceptance tests skipped unless env 'CLOUD_ENV' is set")
 	}
+	t.Parallel()
 	client := common.NewClientFromEnvironment()
 	ctx := context.Background()
 	ipAccessListsAPI := NewIPAccessListsAPI(ctx, client)
diff --git a/clusters/acceptance/cluster_test.go b/clusters/acceptance/cluster_test.go
@@ -7,6 +7,7 @@ import (
 )
 
 func TestAccClusterResource_CreateClusterWithLibraries(t *testing.T) {
+	t.Parallel()
 	acceptance.Test(t, []acceptance.Step{
 		{
 			Template: `
@@ -54,6 +55,7 @@ func TestAccClusterResource_CreateClusterWithLibraries(t *testing.T) {
 }
 
 func TestAccClusterResource_CreateSingleNodeCluster(t *testing.T) {
+	t.Parallel()
 	acceptance.Test(t, []acceptance.Step{
 		{
 			Template: `
diff --git a/clusters/acceptance/clusters_api_test.go b/clusters/acceptance/clusters_api_test.go
@@ -19,7 +19,7 @@ func TestAccListClustersIntegration(t *testing.T) {
 	if cloudEnv == "" {
 		t.Skip("Acceptance tests skipped unless env 'CLOUD_ENV' is set")
 	}
-
+	t.Parallel()
 	client := common.CommonEnvironmentClient()
 	ctx := context.Background()
 	clustersAPI := clusters.NewClustersAPI(ctx, client)
diff --git a/commands/acceptance/commands_test.go b/commands/acceptance/commands_test.go
@@ -17,6 +17,7 @@ func TestAccContext(t *testing.T) {
 	if cloud == "" {
 		t.Skip("Acceptance tests skipped unless env 'CLOUD_ENV' is set")
 	}
+	t.Parallel()
 	client := common.CommonEnvironmentClient()
 	clusterInfo := compute.NewTinyClusterInCommonPoolPossiblyReused()
 	clusterID := clusterInfo.ClusterID
diff --git a/jobs/acceptance/job_test.go b/jobs/acceptance/job_test.go
@@ -177,7 +177,7 @@ func TestAccJobResource(t *testing.T) {
 	if _, ok := os.LookupEnv("CLOUD_ENV"); !ok {
 		t.Skip("Acceptance tests skipped unless env 'CLOUD_ENV' is set")
 	}
-
+	t.Parallel()
 	clustersAPI := clusters.NewClustersAPI(context.Background(), common.CommonEnvironmentClient())
 	sparkVersion := clustersAPI.LatestSparkVersionOrDefault(clusters.SparkVersionRequest{Latest: true, LongTermSupport: true})
 	acceptance.AccTest(t, resource.TestCase{
diff --git a/libraries/acceptance/libraries_api_test.go b/libraries/acceptance/libraries_api_test.go
@@ -17,6 +17,7 @@ func TestAccLibraryCreate(t *testing.T) {
 	if cloud == "" {
 		t.Skip("Acceptance tests skipped unless env 'CLOUD_ENV' is set")
 	}
+	t.Parallel()
 	client := common.CommonEnvironmentClient()
 	clusterInfo, err := compute.NewTinyClusterInCommonPool()
 	assert.NoError(t, err, err)
diff --git a/mlflow/acceptance/mlflow_experiment_test.go b/mlflow/acceptance/mlflow_experiment_test.go
@@ -7,6 +7,7 @@ import (
 )
 
 func TestAccMLflowExperiment(t *testing.T) {
+	t.Parallel()
 	acceptance.Test(t, []acceptance.Step{
 		{
 			Template: `
diff --git a/mlflow/acceptance/mlflow_model_test.go b/mlflow/acceptance/mlflow_model_test.go
@@ -7,6 +7,7 @@ import (
 )
 
 func TestAccMLflowModel(t *testing.T) {
+	t.Parallel()
 	acceptance.Test(t, []acceptance.Step{
 		{
 			Template: `
diff --git a/permissions/acceptance/api_test.go b/permissions/acceptance/api_test.go
@@ -26,6 +26,7 @@ func permissionsTestHelper(t *testing.T,
 	if os.Getenv("CLOUD_ENV") == "" {
 		t.Skip("Acceptance tests skipped unless env 'CLOUD_ENV' is set")
 	}
+	t.Parallel()
 	randomName := acctest.RandStringFromCharSet(10, acctest.CharSetAlphaNum)
 	client := common.NewClientFromEnvironment()
 
diff --git a/permissions/acceptance/permissions_test.go b/permissions/acceptance/permissions_test.go
@@ -15,6 +15,7 @@ import (
 )
 
 func TestAccDatabricksPermissionsResourceFullLifecycle(t *testing.T) {
+	t.Parallel()
 	randomName := acctest.RandStringFromCharSet(10, acctest.CharSetAlphaNum)
 	acceptance.AccTest(t, resource.TestCase{
 		Steps: []resource.TestStep{
@@ -88,6 +89,7 @@ func TestAccDatabricksPermissionsResourceFullLifecycle(t *testing.T) {
 }
 
 func TestAccDatabricksReposPermissionsResourceFullLifecycle(t *testing.T) {
+	t.Parallel()
 	randomName := acctest.RandStringFromCharSet(10, acctest.CharSetAlphaNum)
 	acceptance.AccTest(t, resource.TestCase{
 		Steps: []resource.TestStep{
diff --git a/policies/acceptance/cluster_policy_test.go b/policies/acceptance/cluster_policy_test.go
@@ -14,6 +14,7 @@ import (
 )
 
 func TestAccClusterPolicyResourceFullLifecycle(t *testing.T) {
+	t.Parallel()
 	randomName := acctest.RandStringFromCharSet(10, acctest.CharSetAlphaNum)
 	acceptance.AccTest(t, resource.TestCase{
 		Steps: []resource.TestStep{
diff --git a/pools/resource_instance_pool_test.go b/pools/resource_instance_pool_test.go
@@ -13,6 +13,7 @@ import (
 )
 
 func TestAccInstancePools(t *testing.T) {
+	t.Parallel()
 	cloud := os.Getenv("CLOUD_ENV")
 	if cloud == "" {
 		t.Skip("Acceptance tests skipped unless env 'CLOUD_ENV' is set")
@@ -55,8 +56,6 @@ func TestAccInstancePools(t *testing.T) {
 	assert.NoError(t, err, err)
 	assert.Equal(t, poolInfo.InstancePoolID, poolReadInfo.InstancePoolID)
 	assert.Equal(t, pool.InstancePoolName, poolReadInfo.InstancePoolName)
-	assert.Equal(t, pool.MinIdleInstances, poolReadInfo.MinIdleInstances)
-	assert.Equal(t, pool.MaxCapacity, poolReadInfo.MaxCapacity)
 	assert.Equal(t, pool.NodeTypeID, poolReadInfo.NodeTypeID)
 	assert.Equal(t, pool.IdleInstanceAutoTerminationMinutes, poolReadInfo.IdleInstanceAutoTerminationMinutes)
 
diff --git a/repos/acceptance/git_credential_test.go b/repos/acceptance/git_credential_test.go
@@ -11,6 +11,7 @@ import (
 )
 
 func TestAccGitCredentials(t *testing.T) {
+	t.Parallel()
 	acceptance.Test(t, []acceptance.Step{
 		{
 			Template: `resource "databricks_git_credential" "this" {
diff --git a/scim/acceptance/data_group_test.go b/scim/acceptance/data_group_test.go
@@ -29,7 +29,7 @@ func TestAccGroupDataSplitMembers(t *testing.T) {
 	if cloudEnv, ok := os.LookupEnv("CLOUD_ENV"); !ok || cloudEnv != "azure" {
 		t.Skip("This test will only run on Azure. For simplicity.")
 	}
-
+	t.Parallel()
 	ctx := context.Background()
 	client := common.CommonEnvironmentClient()
 
diff --git a/scim/acceptance/group_member_test.go b/scim/acceptance/group_member_test.go
@@ -11,6 +11,7 @@ import (
 )
 
 func TestAccGroupMemberResource(t *testing.T) {
+	t.Parallel()
 	acceptance.Test(t, []acceptance.Step{
 		{
 			Template: `
diff --git a/scim/acceptance/group_test.go b/scim/acceptance/group_test.go
@@ -21,6 +21,7 @@ func TestAccGroupsExternalIdAndScimProvisioning(t *testing.T) {
 	if _, ok := os.LookupEnv("CLOUD_ENV"); !ok {
 		t.Skip("Acceptance tests skipped unless env 'CLOUD_ENV' is set")
 	}
+	t.Parallel()
 	name := qa.RandomName("tfgroup")
 	acceptance.AccTest(t, resource.TestCase{
 		Steps: []resource.TestStep{
@@ -55,6 +56,7 @@ func TestAccGroupResource(t *testing.T) {
 	if _, ok := os.LookupEnv("CLOUD_ENV"); !ok {
 		t.Skip("Acceptance tests skipped unless env 'CLOUD_ENV' is set")
 	}
+	t.Parallel()
 	randomStr := acctest.RandStringFromCharSet(5, acctest.CharSetAlphaNum)
 	displayName := fmt.Sprintf("tf group test %s", randomStr)
 	newDisplayName := fmt.Sprintf("new tf group test %s", randomStr)
@@ -78,6 +80,7 @@ func TestAccGroupResource(t *testing.T) {
 
 func TestAccGroupResource_verify_entitlements(t *testing.T) {
 	// TODO: CHECK THESE RESOURCES FOR GENERIC DESTROY
+	t.Parallel()
 	randomStr := acctest.RandStringFromCharSet(5, acctest.CharSetAlphaNum)
 	displayName := fmt.Sprintf("tf group test %s", randomStr)
 	newDisplayName := fmt.Sprintf("new tf group test %s", randomStr)
diff --git a/scim/acceptance/service_principal_test.go b/scim/acceptance/service_principal_test.go
@@ -11,6 +11,7 @@ func TestAccServicePrincipalResourceOnAzure(t *testing.T) {
 	if cloud, ok := os.LookupEnv("CLOUD_ENV"); !ok || cloud != "azure" {
 		t.Skip("Test is only for CLOUD_ENV=azure")
 	}
+	t.Parallel()
 	acceptance.Test(t, []acceptance.Step{
 		{
 			Template: `resource "databricks_service_principal" "this" {
@@ -25,6 +26,7 @@ func TestAccServicePrincipalResourceOnAws(t *testing.T) {
 	if cloud, ok := os.LookupEnv("CLOUD_ENV"); !ok || cloud != "AWS" {
 		t.Skip("Test is only for CLOUD_ENV=AWS")
 	}
+	t.Parallel()
 	acceptance.Test(t, []acceptance.Step{
 		{
 			Template: `resource "databricks_service_principal" "this" {
diff --git a/scim/acceptance/user_test.go b/scim/acceptance/user_test.go
@@ -19,6 +19,7 @@ func TestAccForceUserImport(t *testing.T) {
 	if _, ok := os.LookupEnv("CLOUD_ENV"); !ok {
 		t.Skip("Acceptance tests skipped unless env 'CLOUD_ENV' is set")
 	}
+	t.Parallel()
 	username := qa.RandomEmail()
 	os.Setenv("TEST_USERNAME", username)
 	ctx := context.Background()
@@ -44,6 +45,7 @@ func TestAccUserResource(t *testing.T) {
 	if _, ok := os.LookupEnv("CLOUD_ENV"); !ok {
 		t.Skip("Acceptance tests skipped unless env 'CLOUD_ENV' is set")
 	}
+	t.Parallel()
 	config := acceptance.EnvironmentTemplate(t, `
 	resource "databricks_user" "first" {
 		user_name = "eerste+{var.RANDOM}@example.com"
diff --git a/scim/groups_test.go b/scim/groups_test.go
@@ -16,6 +16,7 @@ func TestAccGroup(t *testing.T) {
 	if _, ok := os.LookupEnv("CLOUD_ENV"); !ok {
 		t.Skip("Acceptance tests skipped unless env 'CLOUD_ENV' is set")
 	}
+	t.Parallel()
 	client := common.NewClientFromEnvironment()
 
 	ctx := context.Background()
@@ -65,6 +66,7 @@ func TestAccFilterGroup(t *testing.T) {
 	if testing.Short() {
 		t.Skip("skipping integration test in short mode.")
 	}
+	t.Parallel()
 	client := common.NewClientFromEnvironment()
 	ctx := context.Background()
 	groupsAPI := NewGroupsAPI(ctx, client)
diff --git a/scim/resource_service_principal_test.go b/scim/resource_service_principal_test.go
@@ -17,7 +17,7 @@ func TestAccServicePrincipalOnAzure(t *testing.T) {
 	if cloud, ok := os.LookupEnv("CLOUD_ENV"); !ok || cloud != "azure" {
 		t.Skip("Test will only run with CLOUD_ENV=azure")
 	}
-
+	t.Parallel()
 	client := common.NewClientFromEnvironment()
 	ctx := context.Background()
 
diff --git a/scim/users_test.go b/scim/users_test.go
@@ -19,7 +19,7 @@ func TestAccReadUser(t *testing.T) {
 	if _, ok := os.LookupEnv("CLOUD_ENV"); !ok {
 		t.Skip("Acceptance tests skipped unless env 'CLOUD_ENV' is set")
 	}
-
+	t.Parallel()
 	client := common.NewClientFromEnvironment()
 	ctx := context.Background()
 	usersAPI := NewUsersAPI(ctx, client)
@@ -38,7 +38,7 @@ func TestAccCreateUser(t *testing.T) {
 	if _, ok := os.LookupEnv("CLOUD_ENV"); !ok {
 		t.Skip("Acceptance tests skipped unless env 'CLOUD_ENV' is set")
 	}
-
+	t.Parallel()
 	client := common.NewClientFromEnvironment()
 	randomName := acctest.RandStringFromCharSet(10, acctest.CharSetAlphaNum)
 	ctx := context.Background()
diff --git a/secrets/acceptance/secret_acl_test.go b/secrets/acceptance/secret_acl_test.go
@@ -20,6 +20,7 @@ func TestAccSecretAclResource(t *testing.T) {
 	if _, ok := os.LookupEnv("CLOUD_ENV"); !ok {
 		t.Skip("Acceptance tests skipped unless env 'CLOUD_ENV' is set")
 	}
+	t.Parallel()
 	acceptance.AccTest(t, resource.TestCase{
 		Steps: []resource.TestStep{
 			{
@@ -65,6 +66,7 @@ func TestAccSecretAclResource(t *testing.T) {
 }
 
 func TestAccSecretAclResourceDefaultPrincipal(t *testing.T) {
+	t.Parallel()
 	acceptance.AccTest(t, resource.TestCase{
 		Steps: []resource.TestStep{
 			{
diff --git a/secrets/acceptance/secret_scope_test.go b/secrets/acceptance/secret_scope_test.go
@@ -23,6 +23,7 @@ func TestAccRemoveScopes(t *testing.T) {
 	if _, ok := os.LookupEnv("VSCODE_PID"); !ok {
 		t.Skip("Cleaning up tests only from IDE")
 	}
+	t.Parallel()
 	client := common.CommonEnvironmentClient()
 	scopesAPI := secrets.NewSecretScopesAPI(context.Background(), client)
 	scopeList, err := scopesAPI.List()
@@ -66,6 +67,7 @@ func TestAccInitialManagePrincipals(t *testing.T) {
 	if _, ok := os.LookupEnv("CLOUD_ENV"); !ok {
 		t.Skip("Acceptance tests skipped unless env 'CLOUD_ENV' is set")
 	}
+	t.Parallel()
 	ctx := context.Background()
 	client := common.CommonEnvironmentClient()
 	scopesAPI := secrets.NewSecretScopesAPI(context.Background(), client)
@@ -92,6 +94,7 @@ func TestAccInitialManagePrincipalsGroup(t *testing.T) {
 	if _, ok := os.LookupEnv("CLOUD_ENV"); !ok {
 		t.Skip("Acceptance tests skipped unless env 'CLOUD_ENV' is set")
 	}
+	t.Parallel()
 	client := common.CommonEnvironmentClient()
 	ctx := context.Background()
 	scopesAPI := secrets.NewSecretScopesAPI(ctx, client)
@@ -117,6 +120,7 @@ func TestAccSecretScopeResource(t *testing.T) {
 	if _, ok := os.LookupEnv("CLOUD_ENV"); !ok {
 		t.Skip("Acceptance tests skipped unless env 'CLOUD_ENV' is set")
 	}
+	t.Parallel()
 	scope := qa.RandomName("tf-")
 	acceptance.AccTest(t, resource.TestCase{
 		Steps: []resource.TestStep{
diff --git a/secrets/acceptance/secret_test.go b/secrets/acceptance/secret_test.go
@@ -19,6 +19,7 @@ func TestAccSecretResource(t *testing.T) {
 	if _, ok := os.LookupEnv("CLOUD_ENV"); !ok {
 		t.Skip("Acceptance tests skipped unless env 'CLOUD_ENV' is set")
 	}
+	t.Parallel()
 	config := acceptance.EnvironmentTemplate(t, `
 	resource "databricks_secret_scope" "this" {
 		name = "tf-scope-{var.RANDOM}"
diff --git a/storage/acceptance/common_test.go b/storage/acceptance/common_test.go
@@ -48,6 +48,7 @@ func mountPointThroughReusedCluster(t *testing.T) (*common.DatabricksClient, sto
 	if _, ok := os.LookupEnv("CLOUD_ENV"); !ok {
 		t.Skip("Acceptance tests skipped unless env 'CLOUD_ENV' is set")
 	}
+	t.Parallel()
 	ctx := context.Background()
 	client := common.CommonEnvironmentClient()
 	clusterInfo := compute.NewTinyClusterInCommonPoolPossiblyReused()
diff --git a/storage/acceptance/dbfs_file_test.go b/storage/acceptance/dbfs_file_test.go
@@ -7,6 +7,7 @@ import (
 )
 
 func TestAccDatabricksDBFSFile_CreateViaContent(t *testing.T) {
+	t.Parallel()
 	acceptance.Test(t, []acceptance.Step{
 		{
 			Template: `resource "databricks_dbfs_file" "this" {
@@ -24,6 +25,7 @@ func TestAccDatabricksDBFSFile_CreateViaContent(t *testing.T) {
 }
 
 func TestAccDatabricksDBFSFile_CreateViaSource(t *testing.T) {
+	t.Parallel()
 	acceptance.Test(t, []acceptance.Step{
 		{
 			Template: `resource "databricks_dbfs_file" "file_1" {
diff --git a/storage/dbfs_test.go b/storage/dbfs_test.go
@@ -155,7 +155,7 @@ func TestAccCreateFile(t *testing.T) {
 	if _, ok := os.LookupEnv("CLOUD_ENV"); !ok {
 		t.Skip("Acceptance tests skipped unless env 'CLOUD_ENV' is set")
 	}
-
+	t.Parallel()
 	randomName := acctest.RandStringFromCharSet(10, acctest.CharSetAlphaNum)
 	dir := "/client-test/" + randomName
 	path := dir + "/randomfile"
diff --git a/tokens/acceptance/token_test.go b/tokens/acceptance/token_test.go
@@ -12,6 +12,7 @@ import (
 )
 
 func TestAccTokenResource(t *testing.T) {
+	t.Parallel()
 	acceptance.Test(t, []acceptance.Step{
 		{
 			Template: `resource "databricks_token" "this" {
diff --git a/tokens/resource_token_test.go b/tokens/resource_token_test.go
@@ -260,7 +260,7 @@ func TestAccCreateToken(t *testing.T) {
 	if _, ok := os.LookupEnv("CLOUD_ENV"); !ok {
 		t.Skip("Acceptance tests skipped unless env 'CLOUD_ENV' is set")
 	}
-
+	t.Parallel()
 	client := common.NewClientFromEnvironment()
 	tokensAPI := NewTokensAPI(context.Background(), client)
 
@@ -289,7 +289,7 @@ func TestAccCreateToken_NoExpiration(t *testing.T) {
 	if _, ok := os.LookupEnv("CLOUD_ENV"); !ok {
 		t.Skip("Acceptance tests skipped unless env 'CLOUD_ENV' is set")
 	}
-
+	t.Parallel()
 	client := common.NewClientFromEnvironment()
 	tokensAPI := NewTokensAPI(context.Background(), client)
 
diff --git a/workspace/acceptance/global_init_script_test.go b/workspace/acceptance/global_init_script_test.go
@@ -7,6 +7,7 @@ import (
 )
 
 func TestAccGlobalInitScriptResource_Create(t *testing.T) {
+	t.Parallel()
 	acceptance.Test(t, []acceptance.Step{
 		{
 			Template: `
diff --git a/workspace/acceptance/notebook_test.go b/workspace/acceptance/notebook_test.go
@@ -7,6 +7,7 @@ import (
 )
 
 func TestAccNotebookResourceScalability(t *testing.T) {
+	t.Parallel()
 	acceptance.Test(t, []acceptance.Step{
 		{
 			Template: `resource "databricks_notebook" "this" {
diff --git a/workspace/acceptance/workspace_conf_test.go b/workspace/acceptance/workspace_conf_test.go
@@ -11,6 +11,7 @@ import (
 )
 
 func TestAccWorkspaceConfFullLifecycle(t *testing.T) {
+	t.Parallel()
 	acceptance.Test(t, []acceptance.Step{
 		{
 			Template: `resource "databricks_workspace_conf" "this" {

Original file line number	Diff line number	Diff line change
`@@ -20,7 +20,7 @@ func TestAccTableACL(t *testing.T) {`
`20`	`20`	`if cloudEnv == "" {`
`21`	`21`	`t.Skip("Acceptance tests skipped unless env 'CLOUD_ENV' is set")`
`22`	`22`	`}`
`23`		`-`
	`23`	`+ t.Parallel()`
`24`	`24`	`client := common.CommonEnvironmentClient()`
`25`	`25`	`client.WithCommandExecutor(func(ctx context.Context,`
`26`	`26`	`dc *common.DatabricksClient) common.CommandExecutor {`
Original file line number	Diff line number	Diff line change
`@@ -30,6 +30,7 @@ func TestAccIPACL(t *testing.T) {`
`30`	`30`	`if cloud == "" {`
`31`	`31`	`t.Skip("Acceptance tests skipped unless env 'CLOUD_ENV' is set")`
`32`	`32`	`}`
	`33`	`+ t.Parallel()`
`33`	`34`	`client := common.NewClientFromEnvironment()`
`34`	`35`	`ctx := context.Background()`
`35`	`36`	`ipAccessListsAPI := NewIPAccessListsAPI(ctx, client)`
Original file line number	Diff line number	Diff line change
`@@ -7,6 +7,7 @@ import (`
`7`	`7`	`)`
`8`	`8`
`9`	`9`	`func TestAccClusterResource_CreateClusterWithLibraries(t *testing.T) {`
	`10`	`+ t.Parallel()`
`10`	`11`	`acceptance.Test(t, []acceptance.Step{`
`11`	`12`	`{`
`12`	`13`	Template: `
`@@ -54,6 +55,7 @@ func TestAccClusterResource_CreateClusterWithLibraries(t *testing.T) {`
`54`	`55`	`}`
`55`	`56`
`56`	`57`	`func TestAccClusterResource_CreateSingleNodeCluster(t *testing.T) {`
	`58`	`+ t.Parallel()`
`57`	`59`	`acceptance.Test(t, []acceptance.Step{`
`58`	`60`	`{`
`59`	`61`	Template: `
Original file line number	Diff line number	Diff line change
`@@ -19,7 +19,7 @@ func TestAccListClustersIntegration(t *testing.T) {`
`19`	`19`	`if cloudEnv == "" {`
`20`	`20`	`t.Skip("Acceptance tests skipped unless env 'CLOUD_ENV' is set")`
`21`	`21`	`}`
`22`		`-`
	`22`	`+ t.Parallel()`
`23`	`23`	`client := common.CommonEnvironmentClient()`
`24`	`24`	`ctx := context.Background()`
`25`	`25`	`clustersAPI := clusters.NewClustersAPI(ctx, client)`
Original file line number	Diff line number	Diff line change
`@@ -17,6 +17,7 @@ func TestAccContext(t *testing.T) {`
`17`	`17`	`if cloud == "" {`
`18`	`18`	`t.Skip("Acceptance tests skipped unless env 'CLOUD_ENV' is set")`
`19`	`19`	`}`
	`20`	`+ t.Parallel()`
`20`	`21`	`client := common.CommonEnvironmentClient()`
`21`	`22`	`clusterInfo := compute.NewTinyClusterInCommonPoolPossiblyReused()`
`22`	`23`	`clusterID := clusterInfo.ClusterID`
Original file line number	Diff line number	Diff line change
`@@ -177,7 +177,7 @@ func TestAccJobResource(t *testing.T) {`
`177`	`177`	`if _, ok := os.LookupEnv("CLOUD_ENV"); !ok {`
`178`	`178`	`t.Skip("Acceptance tests skipped unless env 'CLOUD_ENV' is set")`
`179`	`179`	`}`
`180`		`-`
	`180`	`+ t.Parallel()`
`181`	`181`	`clustersAPI := clusters.NewClustersAPI(context.Background(), common.CommonEnvironmentClient())`
`182`	`182`	`sparkVersion := clustersAPI.LatestSparkVersionOrDefault(clusters.SparkVersionRequest{Latest: true, LongTermSupport: true})`
`183`	`183`	`acceptance.AccTest(t, resource.TestCase{`
Original file line number	Diff line number	Diff line change
`@@ -17,6 +17,7 @@ func TestAccLibraryCreate(t *testing.T) {`
`17`	`17`	`if cloud == "" {`
`18`	`18`	`t.Skip("Acceptance tests skipped unless env 'CLOUD_ENV' is set")`
`19`	`19`	`}`
	`20`	`+ t.Parallel()`
`20`	`21`	`client := common.CommonEnvironmentClient()`
`21`	`22`	`clusterInfo, err := compute.NewTinyClusterInCommonPool()`
`22`	`23`	`assert.NoError(t, err, err)`
Original file line number	Diff line number	Diff line change
`@@ -7,6 +7,7 @@ import (`
`7`	`7`	`)`
`8`	`8`
`9`	`9`	`func TestAccMLflowExperiment(t *testing.T) {`
	`10`	`+ t.Parallel()`
`10`	`11`	`acceptance.Test(t, []acceptance.Step{`
`11`	`12`	`{`
`12`	`13`	Template: `
Original file line number	Diff line number	Diff line change
`@@ -7,6 +7,7 @@ import (`
`7`	`7`	`)`
`8`	`8`
`9`	`9`	`func TestAccMLflowModel(t *testing.T) {`
	`10`	`+ t.Parallel()`
`10`	`11`	`acceptance.Test(t, []acceptance.Step{`
`11`	`12`	`{`
`12`	`13`	Template: `
Original file line number	Diff line number	Diff line change
`@@ -26,6 +26,7 @@ func permissionsTestHelper(t *testing.T,`
`26`	`26`	`if os.Getenv("CLOUD_ENV") == "" {`
`27`	`27`	`t.Skip("Acceptance tests skipped unless env 'CLOUD_ENV' is set")`
`28`	`28`	`}`
	`29`	`+ t.Parallel()`
`29`	`30`	`randomName := acctest.RandStringFromCharSet(10, acctest.CharSetAlphaNum)`
`30`	`31`	`client := common.NewClientFromEnvironment()`
`31`	`32`