upsert on the batched action

joaobarraca · joaobarraca · commit 27b7923b5d41 · 2024-11-21T10:55:19.000Z
diff --git a/Extensions/AzureTableAPI/Cosmos.DataTransfer.AzureTableAPIExtension/AzureTableAPIDataSinkExtension.cs b/Extensions/AzureTableAPI/Cosmos.DataTransfer.AzureTableAPIExtension/AzureTableAPIDataSinkExtension.cs
@@ -63,7 +63,7 @@ private static async IAsyncEnumerable<List<TableEntity>> GetBatches(IAsyncEnumer
 
         private static async Task InnerWriteAsync(List<TableEntity> tableEntities, TableClient tableClient, ILogger logger, CancellationToken cancellationToken)
         {
-            var transactionsActions = tableEntities.Select(e => new TableTransactionAction(TableTransactionActionType.Add, e));
+            var transactionsActions = tableEntities.Select(e => new TableTransactionAction(TableTransactionActionType.UpsertReplace, e));
 
             try
             {

Original file line number	Diff line number	Diff line change
`@@ -63,7 +63,7 @@ private static async IAsyncEnumerable<List<TableEntity>> GetBatches(IAsyncEnumer`
`63`	`63`
`64`	`64`	`private static async Task InnerWriteAsync(List<TableEntity> tableEntities, TableClient tableClient, ILogger logger, CancellationToken cancellationToken)`
`65`	`65`	`{`
`66`		`- var transactionsActions = tableEntities.Select(e => new TableTransactionAction(TableTransactionActionType.Add, e));`
	`66`	`+ var transactionsActions = tableEntities.Select(e => new TableTransactionAction(TableTransactionActionType.UpsertReplace, e));`
`67`	`67`
`68`	`68`	`try`
`69`	`69`	`{`