continue try to get resource when not found

Signed-off-by: guoyao <1015105054@qq.com>
This commit is contained in:
guoyao 2021-11-10 15:58:43 +08:00
parent 80df5e66c1
commit 193e00d832
1 changed files with 6 additions and 0 deletions

View File

@ -260,11 +260,17 @@ func generateSecretInMemberCluster(clusterKubeClient kubeclient.Interface, clust
err = wait.Poll(1*time.Second, 30*time.Second, func() (done bool, err error) {
serviceAccount, err := clusterKubeClient.CoreV1().ServiceAccounts(serviceAccountObj.Namespace).Get(context.TODO(), serviceAccountObj.Name, metav1.GetOptions{})
if err != nil {
if apierrors.IsNotFound(err) {
return false, nil
}
klog.Errorf("Failed to retrieve service account(%s/%s) from cluster, err: %v", serviceAccountObj.Namespace, serviceAccountObj.Name, err)
return false, err
}
clusterSecret, err = util.GetTargetSecret(clusterKubeClient, serviceAccount.Secrets, corev1.SecretTypeServiceAccountToken, clusterNamespace)
if err != nil {
if apierrors.IsNotFound(err) {
return false, nil
}
return false, err
}