diff --git a/src/modules/Elsa.Workflows.Core/Models/ActivityExecutionContext.cs b/src/modules/Elsa.Workflows.Core/Models/ActivityExecutionContext.cs index 4414bdb0a..8e0f66291 100644 --- a/src/modules/Elsa.Workflows.Core/Models/ActivityExecutionContext.cs +++ b/src/modules/Elsa.Workflows.Core/Models/ActivityExecutionContext.cs @@ -95,13 +95,15 @@ public class ActivityExecutionContext { if (completionCallback != null) await completionCallback(this, this); + else + await owner.CompleteActivityAsync(); return; } WorkflowExecutionContext.Schedule(activity, owner, completionCallback, references, tag); } - public async ValueTask ScheduleActivitiesAsync(params IActivity?[] activities) => await ScheduleActivities((IEnumerable)activities); + public async ValueTask ScheduleActivitiesAsync(params IActivity?[] activities) => await ScheduleActivities(activities); public async ValueTask ScheduleActivities(IEnumerable activities, ActivityCompletionCallback? completionCallback = default) {