mirrors/velero
1
0
Fork 0
mirror of https://github.com/vmware-tanzu/velero.git synced 2026-04-21 00:00:33 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Adress Ashish's second review

Browse Source 
Signed-off-by: Carlisia <carlisia@vmware.com>
This commit is contained in:
Carlisia
2021-03-25 17:21:23 -07:00
parent c64f45e044
commit 6decba9dda
1 changed files with 3 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
pkg/cmd/cli/uninstall/uninstall.go
View File

@@ -147,12 +147,12 @@ func Run(ctx context.Context, client *kubernetes.Clientset, extensionsClient *ap
defer cancel()
checkFunc := func() {
ns, _ := client.CoreV1().Namespaces().Get(ctx, namespace, metav1.GetOptions{})
ns, err := client.CoreV1().Namespaces().Get(ctx, namespace, metav1.GetOptions{})
if err != nil {
if apierrors.IsNotFound(err) {
fmt.Printf("Unexpectedly not able to retrieve namespace %q for checking its status. Halting.\n", namespace)
errs = append(errs, errors.WithStack(err))
fmt.Print("\n")
cancel()
return
}
errs = append(errs, errors.WithStack(err))
}
@@ -160,15 +160,9 @@ func Run(ctx context.Context, client *kubernetes.Clientset, extensionsClient *ap
if ns.Status.Phase == corev1.NamespaceTerminating {
fmt.Print(".")
}
if ns.Status.Phase != corev1.NamespaceTerminating {
fmt.Print("\n")
cancel()
}
}
wait.Until(checkFunc, 5*time.Millisecond, ctx.Done())
}
if kubeerrs.NewAggregate(errs) != nil {