bug

danielgerlag · danielgerlag · commit b34690c5142c · 2021-10-22T19:19:42.000-07:00
diff --git a/src/providers/WorkflowCore.Persistence.EntityFramework/Services/EntityFrameworkPersistenceProvider.cs b/src/providers/WorkflowCore.Persistence.EntityFramework/Services/EntityFrameworkPersistenceProvider.cs
@@ -398,8 +398,9 @@ public async Task ProcessCommands(DateTimeOffset asOf, Func<ScheduledCommand, Ta
                     try
                     {
                         await action(command.ToScheduledCommand());
-                        db.Set<PersistedScheduledCommand>().Remove(command);
-                        await db.SaveChangesAsync();
+                        using var db2 = ConstructDbContext();
+                        db2.Set<PersistedScheduledCommand>().Remove(command);
+                        await db2.SaveChangesAsync();
                     }
                     catch (Exception)
                     {

Original file line number	Diff line number	Diff line change
`@@ -398,8 +398,9 @@ public async Task ProcessCommands(DateTimeOffset asOf, Func<ScheduledCommand, Ta`
`398`	`398`	`try`
`399`	`399`	`{`
`400`	`400`	`await action(command.ToScheduledCommand());`
`401`		`- db.Set<PersistedScheduledCommand>().Remove(command);`
`402`		`- await db.SaveChangesAsync();`
	`401`	`+ using var db2 = ConstructDbContext();`
	`402`	`+ db2.Set<PersistedScheduledCommand>().Remove(command);`
	`403`	`+ await db2.SaveChangesAsync();`
`403`	`404`	`}`
`404`	`405`	`catch (Exception)`
`405`	`406`	`{`