Resolve #957, Add back MongoBulkWriteException

potatopeelings · potatopeelings · commit 23f5f274ca44 · 2021-12-20T09:06:46.000+11:00
diff --git a/src/providers/WorkflowCore.Persistence.MongoDB/Services/MongoPersistenceProvider.cs b/src/providers/WorkflowCore.Persistence.MongoDB/Services/MongoPersistenceProvider.cs
@@ -321,6 +321,12 @@ public async Task ScheduleCommand(ScheduledCommand command)
                      return;
                 throw;
             }
+            catch (MongoBulkWriteException ex)
+            {
+                if (ex.WriteErrors.All(x => x.Category == ServerErrorCategory.DuplicateKey))
+                    return;
+                throw;
+            }
         }
 
         public async Task ProcessCommands(DateTimeOffset asOf, Func<ScheduledCommand, Task> action, CancellationToken cancellationToken = default)

Original file line number	Diff line number	Diff line change
`@@ -321,6 +321,12 @@ public async Task ScheduleCommand(ScheduledCommand command)`
`321`	`321`	`return;`
`322`	`322`	`throw;`
`323`	`323`	`}`
	`324`	`+ catch (MongoBulkWriteException ex)`
	`325`	`+ {`
	`326`	`+ if (ex.WriteErrors.All(x => x.Category == ServerErrorCategory.DuplicateKey))`
	`327`	`+ return;`
	`328`	`+ throw;`
	`329`	`+ }`
`324`	`330`	`}`
`325`	`331`
`326`	`332`	`public async Task ProcessCommands(DateTimeOffset asOf, Func<ScheduledCommand, Task> action, CancellationToken cancellationToken = default)`