diff --git a/src/modules/Elsa.Workflows.Core/Activities/Flowchart/Activities/FlowJoin.cs b/src/modules/Elsa.Workflows.Core/Activities/Flowchart/Activities/FlowJoin.cs index 65390c828..067efafc8 100644 --- a/src/modules/Elsa.Workflows.Core/Activities/Flowchart/Activities/FlowJoin.cs +++ b/src/modules/Elsa.Workflows.Core/Activities/Flowchart/Activities/FlowJoin.cs @@ -43,7 +43,7 @@ public class FlowJoin : Activity, IJoinNode { if (Flowchart.CanWaitAllProceed(context)) { - Flowchart.CancelAncestorActivatesAsync(context); + await Flowchart.CancelAncestorActivitiesAsync(context); await context.CompleteActivityAsync(); } @@ -51,7 +51,7 @@ public class FlowJoin : Activity, IJoinNode } case FlowJoinMode.WaitAny: { - Flowchart.CancelAncestorActivatesAsync(context); + await Flowchart.CancelAncestorActivitiesAsync(context); await context.CompleteActivityAsync(); break; } diff --git a/src/modules/Elsa.Workflows.Core/Activities/Flowchart/Activities/Flowchart.cs b/src/modules/Elsa.Workflows.Core/Activities/Flowchart/Activities/Flowchart.cs index 1d24195ee..217a9315f 100644 --- a/src/modules/Elsa.Workflows.Core/Activities/Flowchart/Activities/Flowchart.cs +++ b/src/modules/Elsa.Workflows.Core/Activities/Flowchart/Activities/Flowchart.cs @@ -351,7 +351,7 @@ public class Flowchart : Container return flowScope.AllInboundConnectionsVisited(flowGraph, activity); } - public static async void CancelAncestorActivatesAsync(ActivityExecutionContext context) + public static async Task CancelAncestorActivitiesAsync(ActivityExecutionContext context) { var flowchartContext = context.ParentActivityExecutionContext!; var flowchart = (Flowchart)flowchartContext.Activity;