fix(migrator): don't insert twice in processeids when retrying #2

Informatievlaanderen · Aug 29, 2023 · 8acffe5 · 8acffe5
1 parent 39e56aa
commit 8acffe5
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/AddressRegistry.Migrator.Address/Infrastructure/StreamMigrator.cs b/src/AddressRegistry.Migrator.Address/Infrastructure/StreamMigrator.cs
@@ -103,7 +103,7 @@ public async Task ProcessAsync(CancellationToken ct)
 
                 try
                 {
-                    var processedPageItems = await ProcessStreams(new (int, string)[] { (retryProcessedId.processedId, retryProcessedId.aggregateId) }, ct);
+                    var processedPageItems = await ProcessStreams(new (int, string)[] { (retryProcessedId.processedId, retryProcessedId.aggregateId) }, ct, true);
 
                     await _processedIdsTable.CompleteRetryPageAsync(processedPageItems);
                 }