Merge branch 'CoreHelpers:master' into feature/onlyrowandpartition

.github/workflows/publish-release.yml

@@ -7,6 +7,8 @@ on:
 jobs:
   build-nuget:
     runs-on: ubuntu-latest
+    permissions:
+      contents: write
     steps:
       - uses: actions/checkout@v2
 

CoreHelpers.WindowsAzure.Storage.Table/Extensions/TableClientExtensions.cs

@@ -49,8 +49,34 @@ public static async Task<Response<IReadOnlyList<Response>>> SubmitTransactionWit
                 // check the exception
                 if (allowAutoCreate && ex.ErrorCode.Equals("TableNotFound"))
                 {
-                    // try to create the table
-                    await tc.CreateAsync();
+
+                    // This is a double check pattern to ensure that two independent processes 
+                    // who are trying to create the table in parallel do not end up in an unhandled
+                    // situation.   
+                    try
+                    {
+                        // try to create the table
+                        await tc.CreateAsync();
+                    }
+                    catch (TableTransactionFailedException doubleCheckEx)
+                    {
+                        // check if we have an errorCode if not the system throws the exception 
+                        // to the caller 
+                        if (String.IsNullOrEmpty(doubleCheckEx.ErrorCode))
+                        {
+                            ExceptionDispatchInfo.Capture(ex).Throw();
+                            return null;
+                        }
+
+                        // Every error except the TableAlreadyExists is thrown to the caller but 
+                        // in the case the system is trying to create the table in parallel we
+                        // ignore the error and execute the transaction!
+                        if (!doubleCheckEx.ErrorCode.Equals("TableAlreadyExists"))
+                        {
+                            ExceptionDispatchInfo.Capture(ex).Throw();
+                            return null;
+                        }
+                    }
 
                     // retry 
                     return await tc.SubmitTransactionAsync(transactionActions, cancellationToken);