ref field

Author: danielgerlag

ReleaseNotes/1.3.0.md

@@ -0,0 +1,20 @@
+# Workflow Core 1.3.0
+
+* Added support for async steps
+
+Simply inherit from `StepBodyAsync` instead of `StepBody`
+
+```c#
+public class DoSomething : StepBodyAsync
+{
+    public override async Task<ExecutionResult> RunAsync(IStepExecutionContext context)
+    {
+        await Task.Delay(2000);
+        return ExecutionResult.Next();
+    }
+}
+```
+
+* Migrated from managing own thread pool to TPL datablocks for queue consumers
+
+* After executing a workflow, will determine if it is scheduled to run before the next poll, if so, will delay queue it

WorkflowCore.sln

@@ -16,6 +16,8 @@ public class WorkflowInstance
 
         public string Description { get; set; }
 
+        public string Reference { get; set; }
+
         public List<ExecutionPointer> ExecutionPointers { get; set; } = new List<ExecutionPointer>();
 
         public long? NextExecution { get; set; }

src/WorkflowCore/Models/WorkflowInstance.cs

@@ -26,8 +26,8 @@
   </ItemGroup>
 
   <ItemGroup>
-    <PackageReference Include="Microsoft.AspNetCore.Mvc.Abstractions" Version="1.1.2" />
-    <PackageReference Include="Microsoft.AspNetCore.Mvc" Version="1.1.2" />
+    <PackageReference Include="Microsoft.AspNetCore.Mvc.Abstractions" Version="1.1.3" />
+    <PackageReference Include="Microsoft.AspNetCore.Mvc" Version="1.1.3" />
     <PackageReference Include="Microsoft.Extensions.Logging.Abstractions" Version="1.1.1" />
   </ItemGroup>
 

src/extensions/WorkflowCore.WebAPI/WorkflowCore.WebAPI.csproj

@@ -19,6 +19,7 @@ internal static PersistedWorkflow ToPersistable(this WorkflowInstance instance,
 
             persistable.Data = JsonConvert.SerializeObject(instance.Data, SerializerSettings);
             persistable.Description = instance.Description;
+            persistable.Reference = instance.Reference;
             persistable.InstanceId = new Guid(instance.Id);
             persistable.NextExecution = instance.NextExecution;
             persistable.Version = instance.Version;
@@ -118,6 +119,7 @@ internal static WorkflowInstance ToWorkflowInstance(this PersistedWorkflow insta
             WorkflowInstance result = new WorkflowInstance();
             result.Data = JsonConvert.DeserializeObject(instance.Data, SerializerSettings);
             result.Description = instance.Description;
+            result.Reference = instance.Reference;
             result.Id = instance.InstanceId.ToString();
             result.NextExecution = instance.NextExecution;
             result.Version = instance.Version;

src/providers/WorkflowCore.Persistence.EntityFramework/ExtensionMethods.cs

@@ -24,6 +24,9 @@ public class PersistedWorkflow
         [MaxLength(500)]
         public string Description { get; set; }
 
+        [MaxLength(200)]
+        public string Reference { get; set; }
+
         public virtual List<PersistedExecutionPointer> ExecutionPointers { get; set; } = new List<PersistedExecutionPointer>();
 
         //[Index]

src/providers/WorkflowCore.Persistence.EntityFramework/Models/PersistedWorkflow.cs

@@ -28,9 +28,9 @@
   </ItemGroup>
 
   <ItemGroup>
-    <PackageReference Include="Microsoft.EntityFrameworkCore" Version="1.1.1" />
-    <PackageReference Include="Microsoft.EntityFrameworkCore.Relational" Version="1.1.1" />
-    <PackageReference Include="Newtonsoft.Json" Version="9.0.1" />
+    <PackageReference Include="Microsoft.EntityFrameworkCore" Version="1.1.2" />
+    <PackageReference Include="Microsoft.EntityFrameworkCore.Relational" Version="1.1.2" />
+    <PackageReference Include="Newtonsoft.Json" Version="10.0.3" />
   </ItemGroup>
 
 </Project>

src/providers/WorkflowCore.Persistence.EntityFramework/WorkflowCore.Persistence.EntityFramework.csproj

@@ -37,6 +37,7 @@ static MongoPersistenceProvider()
                 x.MapProperty(y => y.Data)
                     .SetSerializer(new DataObjectSerializer());
                 x.MapProperty(y => y.Description);
+                x.MapProperty(y => y.Reference);
                 x.MapProperty(y => y.WorkflowDefinitionId);
                 x.MapProperty(y => y.Version);
                 x.MapProperty(y => y.NextExecution);

src/providers/WorkflowCore.Persistence.MongoDB/Services/MongoPersistenceProvider.cs

@@ -28,8 +28,8 @@
   </ItemGroup>
 
   <ItemGroup>
-    <PackageReference Include="MongoDB.Driver" Version="2.4.3" />
-    <PackageReference Include="Newtonsoft.Json" Version="9.0.1" />
+    <PackageReference Include="MongoDB.Driver" Version="2.4.4" />
+    <PackageReference Include="Newtonsoft.Json" Version="10.0.3" />
     <PackageReference Include="System.Linq.Dynamic.Core" Version="1.0.6.10" />
   </ItemGroup>