ability to schedule execution pointers dependent another pointer completing first

Author: danielgerlag

WorkflowCore.sln

@@ -103,6 +103,7 @@ Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "ReleaseNotes", "ReleaseNote
 		ReleaseNotes\2.1.2.md = ReleaseNotes\2.1.2.md
 		ReleaseNotes\3.0.0.md = ReleaseNotes\3.0.0.md
 		ReleaseNotes\3.1.0.md = ReleaseNotes\3.1.0.md
+		ReleaseNotes\3.3.0.md = ReleaseNotes\3.3.0.md
 	EndProjectSection
 EndProject
 Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "WorkflowCore.Sample14", "src\samples\WorkflowCore.Sample14\WorkflowCore.Sample14.csproj", "{6BC66637-B42A-4334-ADFB-DBEC9F29D293}"
@@ -145,9 +146,9 @@ Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "WorkflowCore.Sample09s", "s
 EndProject
 Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "ScratchPad", "test\ScratchPad\ScratchPad.csproj", "{51BB7DCD-01DD-453D-A1E7-17E5E3DBB14C}"
 EndProject
-Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "WorkflowCore.Tests.QueueProviders.RabbitMQ", "test\WorkflowCore.Tests.QueueProviders.RabbitMQ\WorkflowCore.Tests.QueueProviders.RabbitMQ.csproj", "{54DE20BA-EBA7-4BF0-9BD9-F03766849716}"
+Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "WorkflowCore.Tests.QueueProviders.RabbitMQ", "test\WorkflowCore.Tests.QueueProviders.RabbitMQ\WorkflowCore.Tests.QueueProviders.RabbitMQ.csproj", "{54DE20BA-EBA7-4BF0-9BD9-F03766849716}"
 EndProject
-Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "WorkflowCore.Sample19", "src\samples\WorkflowCore.Sample19\WorkflowCore.Sample19.csproj", "{1223ED47-3E5E-4960-B70D-DFAF550F6666}"
+Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "WorkflowCore.Sample19", "src\samples\WorkflowCore.Sample19\WorkflowCore.Sample19.csproj", "{1223ED47-3E5E-4960-B70D-DFAF550F6666}"
 EndProject
 Global
 	GlobalSection(SolutionConfigurationPlatforms) = preSolution

src/WorkflowCore/Models/ExecutionPointer.cs

@@ -63,6 +63,7 @@ public enum PointerStatus
         WaitingForEvent = 5,
         Failed = 6,
         Compensated = 7,
-        Cancelled = 8
+        Cancelled = 8,
+        PendingPredecessor = 9
     }
 }

src/WorkflowCore/Models/ExecutionPointerCollection.cs

@@ -97,6 +97,12 @@ public ExecutionPointer Find(Predicate<ExecutionPointer> match)
             return _dictionary.Values.FirstOrDefault(x => match(x));
         }
 
+        public ICollection<ExecutionPointer> FindByStatus(PointerStatus status)
+        {
+            //TODO: track states in hash table
+            return _dictionary.Values.Where(x => x.Status == status).ToList();
+        }
+
         public int Count => _dictionary.Count;
         public bool IsReadOnly => false;
     }

src/WorkflowCore/Services/ErrorHandlers/CompensateHandler.cs

@@ -63,11 +63,13 @@ public void Handle(WorkflowInstance workflow, WorkflowDefinition def, ExecutionP
                 scopePointer.EndTime = _datetimeProvider.UtcNow;
                 scopePointer.Status = PointerStatus.Failed;
 
+                ExecutionPointer compensationPointer = null;
+
                 if (scopeStep.CompensationStepId.HasValue)
                 {
                     scopePointer.Status = PointerStatus.Compensated;
 
-                    var compensationPointer = _pointerFactory.BuildCompensationPointer(def, scopePointer, exceptionPointer, scopeStep.CompensationStepId.Value);
+                    compensationPointer = _pointerFactory.BuildCompensationPointer(def, scopePointer, exceptionPointer, scopeStep.CompensationStepId.Value);
                     workflow.ExecutionPointers.Add(compensationPointer);
 
                     if (resume)
@@ -89,8 +91,16 @@ public void Handle(WorkflowInstance workflow, WorkflowDefinition def, ExecutionP
                         var siblingStep = def.Steps.FindById(siblingPointer.StepId);
                         if (siblingStep.CompensationStepId.HasValue)
                         {
-                            var compensationPointer = _pointerFactory.BuildCompensationPointer(def, siblingPointer, exceptionPointer, siblingStep.CompensationStepId.Value);
-                            workflow.ExecutionPointers.Add(compensationPointer);
+                            var nextCompensationPointer = _pointerFactory.BuildCompensationPointer(def, siblingPointer, exceptionPointer, siblingStep.CompensationStepId.Value);
+                            if (compensationPointer != null)
+                            {
+                                nextCompensationPointer.Active = false;
+                                nextCompensationPointer.Status = PointerStatus.PendingPredecessor;
+                                nextCompensationPointer.PredecessorId = compensationPointer.Id;
+                                compensationPointer = nextCompensationPointer;
+                            }
+                            workflow.ExecutionPointers.Add(nextCompensationPointer);
+
                             siblingPointer.Status = PointerStatus.Compensated;
                         }
                     }

src/WorkflowCore/Services/ExecutionResultProcessor.cs

@@ -67,6 +67,16 @@ public void ProcessExecutionResult(WorkflowInstance workflow, WorkflowDefinition
                     workflow.ExecutionPointers.Add(_pointerFactory.BuildNextPointer(def, pointer, outcomeTarget));
                 }
 
+                var pendingSubsequents = workflow.ExecutionPointers
+                    .FindByStatus(PointerStatus.PendingPredecessor)
+                    .Where(x => x.PredecessorId == pointer.Id);
+
+                foreach (var subsequent in pendingSubsequents)
+                {
+                    subsequent.Status = PointerStatus.Pending;
+                    subsequent.Active = true;
+                }
+
                 _eventPublisher.PublishNotification(new StepCompleted()
                 {
                     EventTimeUtc = _datetimeProvider.UtcNow,

src/WorkflowCore/WorkflowCore.csproj

@@ -15,12 +15,12 @@
     <GenerateAssemblyCompanyAttribute>false</GenerateAssemblyCompanyAttribute>
     <GenerateAssemblyProductAttribute>false</GenerateAssemblyProductAttribute>
     <Description>Workflow Core is a light weight workflow engine targeting .NET Standard.</Description>
-    <Version>3.3.1</Version>
-    <AssemblyVersion>3.3.1.0</AssemblyVersion>
-    <FileVersion>3.3.1.0</FileVersion>
+    <Version>3.3.2</Version>
+    <AssemblyVersion>3.3.2.0</AssemblyVersion>
+    <FileVersion>3.3.2.0</FileVersion>
     <PackageReleaseNotes></PackageReleaseNotes>
     <PackageIconUrl>https://github.com/danielgerlag/workflow-core/raw/master/src/logo.png</PackageIconUrl>
-    <PackageVersion>3.3.1</PackageVersion>
+    <PackageVersion>3.3.2</PackageVersion>
   </PropertyGroup>
 
   <ItemGroup>

test/WorkflowCore.IntegrationTests/Scenarios/MultistepCompensationScenario.cs

@@ -34,11 +34,11 @@ public void Build(IWorkflowBuilder<object> builder)
                                 Compensation1Fired = CompensationCounter;
                             })
                         .Then(context => ExecutionResult.Next())
-                            .CompensateWith(context =>
+                            .CompensateWithSequence(context => context.StartWith(c =>
                             {
                                 CompensationCounter++;
                                 Compensation2Fired = CompensationCounter;
-                            })
+                            }))
                         .Then(context => ExecutionResult.Next())
                             .CompensateWith(context =>
                             {