1055
}
1056
}
1057
>
stage.MarkProcessed(tasks.DeleteWorkflowExecutionStageCurrent)
context_impl.go
1058
>
1059
>
// Stage 3. Delete workflow mutable state.
1060
>
if !stage.IsProcessed(tasks.DeleteWorkflowExecutionStageMutableState) {
1061
>
ctx, cancel, err := validateCtxAndShardState()
1062
>
if err != nil {
1063
return err
1064
}
1066
>
if err := s.GetExecutionManager().DeleteWorkflowExecution(
1067
>
ctx,
1068
>
&persistence.DeleteWorkflowExecutionRequest{
1069
>
ShardID: s.shardID,
1070
>
NamespaceID: key.NamespaceID,
1071
>
WorkflowID: key.WorkflowID,
1072
>
RunID: key.RunID,
1073
>
ArchetypeID: archetypeID,
1074
>
},
1075
>
); err != nil {
1076
return err
1077
}
1078
}
1079
>
stage.MarkProcessed(tasks.DeleteWorkflowExecutionStageMutableState)
context_impl.go
1080
>
1081
>
return nil
1082
}(); err != nil {
1083
return err