remove DMS resource lock

Author: chengxiangdong

huaweicloud/services/acceptance/dms/data_source_huaweicloud_dms_kafka_instances_test.go

@@ -17,7 +17,7 @@ func TestAccKafkaInstancesDataSource_basic(t *testing.T) {
 	dc3 := acceptance.InitDataSourceCheck("data.huaweicloud_dms_kafka_instances.query_3")
 	dc4 := acceptance.InitDataSourceCheck("data.huaweicloud_dms_kafka_instances.query_4")
 
-	resource.Test(t, resource.TestCase{
+	resource.ParallelTest(t, resource.TestCase{
 		PreCheck:          func() { acceptance.TestAccPreCheck(t) },
 		ProviderFactories: acceptance.TestAccProviderFactories,
 		Steps: []resource.TestStep{

huaweicloud/services/dms/resource_huaweicloud_dms_kafka_instance.go

@@ -397,9 +397,6 @@ func updateCrossVpcAccess(client *golangsdk.ServiceClient, d *schema.ResourceDat
 }
 
 func resourceDmsKafkaInstanceCreate(ctx context.Context, d *schema.ResourceData, meta interface{}) diag.Diagnostics {
-	config.MutexKV.Lock(lockKey)
-	defer config.MutexKV.Unlock(lockKey)
-
 	cfg := meta.(*config.Config)
 	client, err := cfg.DmsV2Client(cfg.GetRegion(d))
 	if err != nil {
@@ -779,9 +776,6 @@ func resourceDmsKafkaInstanceRead(_ context.Context, d *schema.ResourceData, met
 }
 
 func resourceDmsKafkaInstanceUpdate(ctx context.Context, d *schema.ResourceData, meta interface{}) diag.Diagnostics {
-	config.MutexKV.Lock(lockKey)
-	defer config.MutexKV.Unlock(lockKey)
-
 	cfg := meta.(*config.Config)
 	client, err := cfg.DmsV2Client(cfg.GetRegion(d))
 	if err != nil {