143
ms historyi.MutableState,
144
stage *tasks.DeleteWorkflowExecutionStage,
146
>
// Skip replication for retention-based deletion. Both clusters have independent retention
147
>
// timers and will delete on their own schedule.
148
>
stage.MarkProcessed(tasks.DeleteWorkflowExecutionStageReplication)
149
>
150
>
return m.deleteWorkflowExecutionInternal(
151
>
ctx,
152
>
nsID,
153
>
we,
154
>
weCtx,
155
>
ms,
156
>
stage,
157
>
true,
158
>
m.metricsHandler.WithTags(metrics.OperationTag(metrics.HistoryProcessDeleteHistoryEventScope)),
159
>
)
160
>
}
161
162
func (m *DeleteManagerImpl) deleteWorkflowExecutionInternal(