Merge pull request #128 from k-yomo/fix-to-unlock-when-error

Fix to unlock when returning error
k-yomo · Aug 30, 2022 · ef30d3d · ef30d3d
2 parents 267fb40 + 3558074
commit ef30d3d
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/internal/provider/resource_virtual_index.go b/internal/provider/resource_virtual_index.go
@@ -574,6 +574,7 @@ func resourceVirtualIndexCreate(ctx context.Context, d *schema.ResourceData, m i
 	mutexKV.Lock(ctx, algoliaIndexMutexKey(apiClient.appID, primaryIndexName))
 	primaryIndexSettings, err := primaryIndex.GetSettings(ctx)
 	if err != nil {
+		mutexKV.Unlock(ctx, algoliaIndexMutexKey(apiClient.appID, primaryIndexName))
 		return diag.FromErr(err)
 	}
 	replicas := primaryIndexSettings.Replicas.Get()
@@ -584,9 +585,11 @@ func resourceVirtualIndexCreate(ctx context.Context, d *schema.ResourceData, m i
 			Replicas: opt.Replicas(newReplicas...),
 		})
 		if err != nil {
+			mutexKV.Unlock(ctx, algoliaIndexMutexKey(apiClient.appID, primaryIndexName))
 			return diag.FromErr(err)
 		}
 		if err := res.Wait(); err != nil {
+			mutexKV.Unlock(ctx, algoliaIndexMutexKey(apiClient.appID, primaryIndexName))
 			return diag.FromErr(err)
 		}
 	}