From db90b174846d96cce02d5c50993eb56262a1b681 Mon Sep 17 00:00:00 2001 From: Austin Abro Date: Mon, 30 Dec 2024 15:01:52 +0000 Subject: [PATCH] unknown status Signed-off-by: Austin Abro --- pkg/kube/kwait.go | 11 +++++++---- 1 file changed, 7 insertions(+), 4 deletions(-) diff --git a/pkg/kube/kwait.go b/pkg/kube/kwait.go index ae7fcbe43..587c41c49 100644 --- a/pkg/kube/kwait.go +++ b/pkg/kube/kwait.go @@ -94,17 +94,20 @@ func (w *kstatusWaiter) waitForDelete(ctx context.Context, resourceList Resource errs := []error{} for _, id := range resources { rs := statusCollector.ResourceStatuses[id] - if rs.Status == status.CurrentStatus { + if rs.Status == status.NotFoundStatus { continue } - errs = append(errs, fmt.Errorf("%s: %s not ready, status: %s", rs.Identifier.Name, rs.Identifier.GroupKind.Kind, rs.Status)) + if rs.Status == status.UnknownStatus { + errs = append(errs, fmt.Errorf("%s: %s cannot determine if resource exists, status: %s", rs.Identifier.Name, rs.Identifier.GroupKind.Kind, rs.Status)) + continue + } + + errs = append(errs, fmt.Errorf("%s: %s still exists, status: %s", rs.Identifier.Name, rs.Identifier.GroupKind.Kind, rs.Status)) } errs = append(errs, ctx.Err()) return errors.Join(errs...) } return nil - defer cancel() - return nil } func (w *kstatusWaiter) wait(ctx context.Context, resourceList ResourceList, waitForJobs bool) error {