return nil
}
callerInfo := getReplicaitonCallerInfo(e.GetPriority())
namespaceName, apply, nsError := e.GetNamespaceInfo(headers.SetCallerInfo(
context.Background(),
callerInfo,
), e.NamespaceID, e.WorkflowID)
if nsError != nil {
return nsError
e.Logger.Warn("Skipping the replication task",
tag.WorkflowNamespaceID(e.NamespaceID),