816
ctx context.Context,
817
workflowKey definition.WorkflowKey,
819
>
shardContext, err := e.ShardController.GetShardByNamespaceWorkflow(
820
>
namespace.ID(workflowKey.NamespaceID),
821
>
workflowKey.WorkflowID,
822
>
)
823
>
if err != nil {
824
return err
825
}
827
>
if err != nil {
828
return err
829
}
830
>
_, err = engine.DeleteWorkflowExecution(ctx, &historyservice.DeleteWorkflowExecutionRequest{
executable_task.go
831
>
NamespaceId: workflowKey.NamespaceID,
832
>
WorkflowExecution: &commonpb.WorkflowExecution{
833
>
WorkflowId: workflowKey.WorkflowID,
834
>
RunId: workflowKey.RunID,
835
>
},
836
>
ClosedWorkflowOnly: false,
837
>
})
838
>
var notFoundErr *serviceerror.NotFound
839
>
if errors.As(err, ¬FoundErr) {
840
return nil
841
}
843
}
844