Call into Workflow Context's Remove Blocking Activity

This commit is contained in:
Sipke Schoorstra 2021-08-07 18:39:45 +02:00
parent cd43136e74
commit db9df4736f

View file

@ -186,11 +186,8 @@ namespace Elsa.Services.Workflows
var blockingActivities = workflowExecutionContext.WorkflowInstance.BlockingActivities.Where(x => x.ActivityId == activityBlueprint.Id).ToList();
foreach (var blockingActivity in blockingActivities)
{
workflowExecutionContext.WorkflowInstance.BlockingActivities.Remove(blockingActivity);
await _mediator.Publish(new BlockingActivityRemoved(workflowExecutionContext, blockingActivity), cancellationToken);
}
foreach (var blockingActivity in blockingActivities)
await workflowExecutionContext.RemoveBlockingActivityAsync(blockingActivity);
workflowExecutionContext.Resume();
workflowExecutionContext.ScheduleActivity(activityBlueprint.Id);