Improve controller not found error

hercynium · Mar 5, 2025 · 78e16f4 · 78e16f4
1 parent e4c85e4
commit 78e16f4
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/internal/util/k8s/k8s.go b/internal/util/k8s/k8s.go
@@ -58,7 +58,7 @@ func FindPodController(ctx context.Context, kubeClient kubernetes.Clientset, pod
 
 	controller, err := getPodController(ctx, dynamic, res)
 	if err != nil {
-		return nil, &ControllerNotFoundError{fmt.Sprintf("Couldn't find controller of pod %v.%v", pod.Name, pod.Namespace)}
+		return nil, &ControllerNotFoundError{fmt.Sprintf("Couldn't find controller of pod %v.%v: %v", pod.Name, pod.Namespace, err)}
 	}
 
 	log.Info("Found controller for outdated pod", "pod-name", pod.Name, "controller-name", controller.GetName())

diff --git a/internal/util/util.go b/internal/util/util.go
@@ -72,7 +72,7 @@ func PodControllerRateLimiter[T comparable]() workqueue.TypedRateLimiter[T] {
 	limit := rate.Limit(1.0 / (60.0 / restartsPerMinute))
 	limiter := rate.NewLimiter(limit, activeRestartLimit)
 	return workqueue.NewTypedMaxOfRateLimiter(
-		workqueue.NewTypedItemExponentialFailureRateLimiter[T](500*time.Millisecond, 1000*time.Second),
+		//workqueue.NewTypedItemExponentialFailureRateLimiter[T](500*time.Millisecond, 1000*time.Second),
 		// This is only for retry speed and its only the overall factor (not per item)
 		&workqueue.TypedBucketRateLimiter[T]{Limiter: limiter},
 	)