Use CreateContainerIfNotExistsAsync on the Cosmos SDK to be compatibl…

…e with RBAC (#33473) * Use CreateContainerIfNotExistsAsync on the Cosmos SDK to be compatible with RBAC Fixes #33354 * Updates based on review feedback.
dotnet · Apr 5, 2024 · 45448ef · 45448ef
1 parent ee68d71
commit 45448ef
Showing 1 changed file with 2 additions and 7 deletions.
diff --git a/src/EFCore.Cosmos/Storage/Internal/CosmosClientWrapper.cs b/src/EFCore.Cosmos/Storage/Internal/CosmosClientWrapper.cs
@@ -201,22 +201,17 @@ private static async Task<bool> CreateContainerIfNotExistsOnceAsync(
         CancellationToken cancellationToken = default)
     {
         var (parameters, wrapper) = parametersTuple;
-        using var response = await wrapper.Client.GetDatabase(wrapper._databaseId).CreateContainerStreamAsync(
+        var response = await wrapper.Client.GetDatabase(wrapper._databaseId).CreateContainerIfNotExistsAsync(
                 new Azure.Cosmos.ContainerProperties(parameters.Id, "/" + parameters.PartitionKey)
                 {
                     PartitionKeyDefinitionVersion = PartitionKeyDefinitionVersion.V2,
                     DefaultTimeToLive = parameters.DefaultTimeToLive,
                     AnalyticalStoreTimeToLiveInSeconds = parameters.AnalyticalStoreTimeToLiveInSeconds
                 },
-                parameters.Throughput,
+                throughput: parameters.Throughput?.Throughput,
                 cancellationToken: cancellationToken)
             .ConfigureAwait(false);
-        if (response.StatusCode == HttpStatusCode.Conflict)
-        {
-            return false;
-        }
 
-        response.EnsureSuccessStatusCode();
         return response.StatusCode == HttpStatusCode.Created;
     }