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

Fix DispatchWorkflow

Browse source
This commit is contained in:
Sipke Schoorstra 2023-02-17 19:23:34 +01:00
parent a62956b2c0
commit 0a831ff65b
1 changed files with 7 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
src/modules/Elsa.Workflows.Runtime/Activities/DispatchWorkflow.cs
View file

@ -49,18 +49,21 @@ public class DispatchWorkflow : Activity, IBookmarksPersistedHandler
protected override async ValueTask ExecuteAsync(ActivityExecutionContext context)
{
var waitForCompletion = WaitForCompletion.TryGet(context);
var identityGenerator = context.GetRequiredService<IIdentityGenerator>();
var instanceId = identityGenerator.GenerateId();
context.TransientProperties["ChildInstanceId"] = instanceId;
// If we need to wait for the child workflow to complete, create a bookmark.
if (waitForCompletion)
{
var identityGenerator = context.GetRequiredService<IIdentityGenerator>();
var instanceId = identityGenerator.GenerateId();
context.TransientProperties["ChildInstanceId"] = instanceId;
context.CreateBookmark(new DispatchWorkflowBookmark(instanceId));
}
else
// Otherwise, we can complete.
{
// Otherwise, we can complete.
await BookmarksPersistedAsync(context);
await context.CompleteActivityAsync();
}
}
/// <summary>