requeue active tasks

danielgerlag · danielgerlag · commit 0931aab4ba67 · 2019-08-30T09:42:28.000-07:00
diff --git a/src/WorkflowCore/Services/BackgroundTasks/QueueConsumer.cs b/src/WorkflowCore/Services/BackgroundTasks/QueueConsumer.cs
@@ -77,6 +77,8 @@ private async void Execute()
                     if (activeTasks.ContainsKey(item))
                     {
                         secondPasses.Add(item);
+                        if (!EnableSecondPasses)
+                            await QueueProvider.QueueWork(item, Queue);
                         continue;
                     }
 
diff --git a/src/WorkflowCore/WorkflowCore.csproj b/src/WorkflowCore/WorkflowCore.csproj
@@ -15,9 +15,9 @@
     <GenerateAssemblyCompanyAttribute>false</GenerateAssemblyCompanyAttribute>
     <GenerateAssemblyProductAttribute>false</GenerateAssemblyProductAttribute>
     <Description>Workflow Core is a light weight workflow engine targeting .NET Standard.</Description>
-    <Version>2.0.0</Version>
-    <AssemblyVersion>2.0.0.0</AssemblyVersion>
-    <FileVersion>2.0.0.0</FileVersion>
+    <Version>2.0.1</Version>
+    <AssemblyVersion>2.0.1.0</AssemblyVersion>
+    <FileVersion>2.0.1.0</FileVersion>
     <PackageReleaseNotes></PackageReleaseNotes>
     <PackageIconUrl>https://github.com/danielgerlag/workflow-core/raw/master/src/logo.png</PackageIconUrl>
   </PropertyGroup>

Original file line number	Diff line number	Diff line change
`@@ -77,6 +77,8 @@ private async void Execute()`
`77`	`77`	`if (activeTasks.ContainsKey(item))`
`78`	`78`	`{`
`79`	`79`	`secondPasses.Add(item);`
	`80`	`+ if (!EnableSecondPasses)`
	`81`	`+ await QueueProvider.QueueWork(item, Queue);`
`80`	`82`	`continue;`
`81`	`83`	`}`
`82`	`84`