From d45eef33d1b0dfedc1dfcfab763e570b7d6fac19 Mon Sep 17 00:00:00 2001
From: Eugene Andrukh <e.andrukh@onventis.nl>
Date: Thu, 23 Jun 2022 16:34:05 +0300
Subject: [PATCH] Support netstandard2.0 in
 WorkflowCore.Persistence.EntityFramework #1041

---
 .../Services/EntityFrameworkPersistenceProvider.cs   | 12 +++++++-----
 .../WorkflowCore.Persistence.EntityFramework.csproj  |  4 ++--
 2 files changed, 9 insertions(+), 7 deletions(-)

diff --git a/src/providers/WorkflowCore.Persistence.EntityFramework/Services/EntityFrameworkPersistenceProvider.cs b/src/providers/WorkflowCore.Persistence.EntityFramework/Services/EntityFrameworkPersistenceProvider.cs
index 44798a0c9..2411d4d57 100644
--- a/src/providers/WorkflowCore.Persistence.EntityFramework/Services/EntityFrameworkPersistenceProvider.cs
+++ b/src/providers/WorkflowCore.Persistence.EntityFramework/Services/EntityFrameworkPersistenceProvider.cs
@@ -391,16 +391,18 @@ public async Task ProcessCommands(DateTimeOffset asOf, Func<ScheduledCommand, Ta
             {
                 var cursor = db.Set<PersistedScheduledCommand>()
                     .Where(x => x.ExecuteTime < asOf.UtcDateTime.Ticks)
-                    .AsAsyncEnumerable();
+                    .AsEnumerable();
 
-                await foreach (var command in cursor)
+                foreach (var command in cursor)
                 {
                     try
                     {
                         await action(command.ToScheduledCommand());
-                        using var db2 = ConstructDbContext();
-                        db2.Set<PersistedScheduledCommand>().Remove(command);
-                        await db2.SaveChangesAsync();
+                        using (var db2 = ConstructDbContext())
+                        {
+                            db2.Set<PersistedScheduledCommand>().Remove(command);
+                            await db2.SaveChangesAsync();
+                        }
                     }
                     catch (Exception)
                     {
diff --git a/src/providers/WorkflowCore.Persistence.EntityFramework/WorkflowCore.Persistence.EntityFramework.csproj b/src/providers/WorkflowCore.Persistence.EntityFramework/WorkflowCore.Persistence.EntityFramework.csproj
index bb07fffd3..9441af7a4 100644
--- a/src/providers/WorkflowCore.Persistence.EntityFramework/WorkflowCore.Persistence.EntityFramework.csproj
+++ b/src/providers/WorkflowCore.Persistence.EntityFramework/WorkflowCore.Persistence.EntityFramework.csproj
@@ -3,7 +3,7 @@
   <PropertyGroup>
     <AssemblyTitle>Workflow Core EntityFramework Core Persistence Provider</AssemblyTitle>
     <Authors>Daniel Gerlag</Authors>
-    <TargetFrameworks>netstandard2.1;net6.0</TargetFrameworks>
+    <TargetFrameworks>netstandard2.0;net6.0</TargetFrameworks>
     <AssemblyName>WorkflowCore.Persistence.EntityFramework</AssemblyName>
     <PackageId>WorkflowCore.Persistence.EntityFramework</PackageId>
     <PackageTags>workflow;.NET;Core;state machine;WorkflowCore;EntityFramework;EntityFrameworkCore</PackageTags>
@@ -25,7 +25,7 @@
     <PackageReference Include="Microsoft.EntityFrameworkCore.Relational" Version="6.0.3" />
   </ItemGroup>
 
-  <ItemGroup Condition=" '$(TargetFramework)' == 'netstandard2.1' ">
+  <ItemGroup Condition=" '$(TargetFramework)' == 'netstandard2.0' ">
     <PackageReference Include="Microsoft.EntityFrameworkCore" Version="3.1.2" />
     <PackageReference Include="Microsoft.EntityFrameworkCore.Relational" Version="3.1.2" />
   </ItemGroup>