90
// inspectedMS is the mutable-state snapshot examined during verification, captured for the
91
// best-effort "applied" lifecycle event emitted below.
93
>
defer func() {
94
>
if emitLifecycle {
95
e.emitReplicationVerifyApplied(inspectedMS, retErr)
96
}
97
}()
98
100
>
namespaceName, apply, nsError := e.GetNamespaceInfo(headers.SetCallerInfo(
101
>
context.Background(),
102
>
callerInfo,
103
>
), e.NamespaceID, e.WorkflowID)
104
>
if nsError != nil {
105
return nsError
107
e.Logger.Warn("Skipping the replication task",
108
tag.WorkflowNamespaceID(e.NamespaceID),