190
case nil, *serviceerror.NotFound:
191
return nil
193
>
callerInfo := getReplicaitonCallerInfo(e.GetPriority())
194
>
namespaceName, _, nsError := e.GetNamespaceInfo(headers.SetCallerInfo(
195
>
context.Background(),
196
>
callerInfo,
197
>
), e.NamespaceID, e.WorkflowID)
198
>
if nsError != nil {
199
return err
200
}
202
>
defer cancel()
203
>
204
>
if doContinue, resendErr := e.Resend(
205
>
ctx,
206
>
e.SourceClusterName(),
207
>
retryErr,
208
>
ResendAttempt,
209
>
); resendErr != nil || !doContinue {
210
return err
211
}