fix: k8s resource check

flanksource · Dec 23, 2024 · 75219b6 · 75219b6
1 parent bbda04c
commit 75219b6
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/checks/kubernetes_resource.go b/checks/kubernetes_resource.go
@@ -215,7 +215,7 @@ func (c *KubernetesResourceChecker) Check(ctx context.Context, check v1.Kubernet
 			return nil
 		})
 		if retryErr != nil {
-			return results.Failf(retryErr.Error())
+			return results.ErrorMessage(retryErr)
 		}
 	}
 
@@ -239,6 +239,7 @@ func (c *KubernetesResourceChecker) evalWaitFor(ctx context.Context, check v1.Ku
 		waitInterval = wt
 	}
 	var resourceObjs []unstructured.Unstructured
+	var err error
 	var attempts int
 	backoff := retry.WithMaxDuration(waitTimeout, retry.NewConstant(waitInterval))
 	retryErr := retry.Do(ctx, backoff, func(_ctx gocontext.Context) error {
@@ -247,7 +248,7 @@ func (c *KubernetesResourceChecker) evalWaitFor(ctx context.Context, check v1.Ku
 
 		ctx.Tracef("waiting for %d resources, attempt=%d, timeout=%s", check.TotalResources(), attempts, waitTimeout)
 
-		resourceObjs, err := ctx.KubernetesClient().FetchResources(ctx, append(check.StaticResources, check.Resources...)...)
+		resourceObjs, err = ctx.KubernetesClient().FetchResources(ctx, append(check.StaticResources, check.Resources...)...)
 		if err != nil {
 			if apiErrors.IsNotFound(err) {
 				return retry.RetryableError(err)