SemianiakaVY/elsa-core
1
0
Fork 0
Code Issues Pull requests Actions 1 Packages Projects Releases Wiki Activity

Update RunWorkflow activity to return Done if child workflow finished synchronously

Browse source
This commit is contained in:
Sipke Schoorstra 2021-01-30 14:43:18 +01:00
parent 7cfe24ba94
commit 0bb95ec06f
1 changed files with 8 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
src/core/Elsa.Core/Activities/Workflows/RunWorkflow/Activities/RunWorkflow.cs → src/core/Elsa.Core/Activities/Workflows/RunWorkflow/RunWorkflow.cs
View file

@ -1,4 +1,5 @@
using System.Collections.Generic;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading;
using System.Threading.Tasks;
@ -46,13 +47,17 @@ namespace Elsa.Activities.Workflows
var cancellationToken = context.CancellationToken;
var workflowBlueprint = await FindWorkflowBlueprintAsync(cancellationToken);
var workflowInstance = await _workflowScheduler.RunWorkflowAsync(workflowBlueprint!, TenantId, Input, CorrelationId, ContextId, cancellationToken);
var workflowStatus = workflowInstance.WorkflowStatus;
ChildWorkflowInstanceId = workflowInstance.Id;
return Mode switch
{
RunWorkflowMode.FireAndForget => Done(),
RunWorkflowMode.Blocking => Suspend(),
_ => Suspend()
RunWorkflowMode.Blocking when workflowStatus == WorkflowStatus.Finished => Done(),
RunWorkflowMode.Blocking when workflowStatus == WorkflowStatus.Suspended => Suspend(),
RunWorkflowMode.Blocking when workflowStatus == WorkflowStatus.Faulted => Fault($"Workflow {workflowInstance.Id} faulted"),
_ => throw new ArgumentOutOfRangeException(nameof(Mode))
};
}