Force entire Restore operation to enqueued (#6948)

* force the entire restore queue to a semaphore operation * we must ensure to use the proper Enqueue method!
Azure · Sep 12, 2023 · c3f571b · c3f571b
1 parent fb6062a
commit c3f571b
Showing 1 changed file with 11 additions and 7 deletions.
diff --git a/tools/test-proxy/Azure.Sdk.Tools.TestProxy/Store/GitStore.cs b/tools/test-proxy/Azure.Sdk.Tools.TestProxy/Store/GitStore.cs
@@ -172,15 +172,19 @@ public async Task Push(string pathToAssetsJson) {
         public async Task<string> Restore(string pathToAssetsJson) {
             var config = await ParseConfigurationFile(pathToAssetsJson);
 
-            var initialized = IsAssetsRepoInitialized(config);
-
-            if (!initialized)
+            var restoreQueue = InitTasks.GetOrAdd("restore", new TaskQueue());
+            await restoreQueue.EnqueueAsync(async () =>
             {
-                InitializeAssetsRepo(config);
-            }
+                var initialized = IsAssetsRepoInitialized(config);
 
-            CheckoutRepoAtConfig(config, cleanEnabled: true);
-            await BreadCrumb.Update(config);
+                if (!initialized)
+                {
+                    InitializeAssetsRepo(config);
+                }
+
+                CheckoutRepoAtConfig(config, cleanEnabled: true);
+                await BreadCrumb.Update(config);
+            });
 
             return config.AssetsRepoLocation.ToString();
         }