diff --git a/src/modules/Elsa.Workflows.Runtime.ProtoActor/Actors/WorkflowInstanceImpl.cs b/src/modules/Elsa.Workflows.Runtime.ProtoActor/Actors/WorkflowInstanceImpl.cs index 6b37bd907..d85b38f45 100644 --- a/src/modules/Elsa.Workflows.Runtime.ProtoActor/Actors/WorkflowInstanceImpl.cs +++ b/src/modules/Elsa.Workflows.Runtime.ProtoActor/Actors/WorkflowInstanceImpl.cs @@ -47,6 +47,12 @@ internal class WorkflowInstanceImpl( return Task.CompletedTask; } + public override Task OnStopped() + { + _linkedTokenSource.Dispose(); + return Task.CompletedTask; + } + public override Task Create(ProtoCreateWorkflowInstanceRequest request) => throw new NotImplementedException(); public override Task Create(ProtoCreateWorkflowInstanceRequest request, Action respond, Action onError)