[datadog_integration_aws_tag_filter] Prevent concurrency issues with …

…mutex (#2063)
DataDog · Aug 18, 2023 · f19a115 · f19a115
1 parent 5f73c31
commit f19a115
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/datadog/resource_datadog_integration_aws_tag_filter.go b/datadog/resource_datadog_integration_aws_tag_filter.go
@@ -67,6 +67,8 @@ func resourceDatadogIntegrationAwsTagFilterCreate(ctx context.Context, d *schema
 	providerConf := meta.(*ProviderConfiguration)
 	apiInstances := providerConf.DatadogApiInstances
 	auth := providerConf.Auth
+	integrationAwsMutex.Lock()
+	defer integrationAwsMutex.Unlock()
 
 	req := buildDatadogIntegrationAwsTagFilter(d)
 	if _, httpresp, err := apiInstances.GetAWSIntegrationApiV1().CreateAWSTagFilter(auth, *req); err != nil {
@@ -81,6 +83,8 @@ func resourceDatadogIntegrationAwsTagFilterUpdate(ctx context.Context, d *schema
 	providerConf := meta.(*ProviderConfiguration)
 	apiInstances := providerConf.DatadogApiInstances
 	auth := providerConf.Auth
+	integrationAwsMutex.Lock()
+	defer integrationAwsMutex.Unlock()
 
 	req := buildDatadogIntegrationAwsTagFilter(d)
 	if _, httpresp, err := apiInstances.GetAWSIntegrationApiV1().CreateAWSTagFilter(auth, *req); err != nil {
@@ -128,6 +132,8 @@ func resourceDatadogIntegrationAwsTagFilterDelete(ctx context.Context, d *schema
 	providerConf := meta.(*ProviderConfiguration)
 	apiInstances := providerConf.DatadogApiInstances
 	auth := providerConf.Auth
+	integrationAwsMutex.Lock()
+	defer integrationAwsMutex.Unlock()
 
 	accountID, tfNamespace, err := utils.AccountAndNamespaceFromID(d.Id())
 	if err != nil {