476
// no-op
477
return true, nil
479
>
e.Logger.Error(
480
>
"workflow not found in source cluster, proceed to cleanup",
481
>
tag.WorkflowNamespaceID(retryErr.NamespaceId),
482
>
tag.WorkflowID(retryErr.WorkflowId),
483
>
tag.WorkflowRunID(retryErr.RunId),
484
>
)
485
>
// workflow is not found in source cluster, cleanup workflow in target cluster
486
>
return false, e.DeleteWorkflow(
487
>
ctx,
488
>
definition.NewWorkflowKey(
489
>
retryErr.NamespaceId,
490
>
retryErr.WorkflowId,
491
>
retryErr.RunId,
492
>
),
493
>
)
494
case *serviceerrors.RetryReplication:
495
// it is possible that resend will trigger another resend, e.g.