fix adding key to delete Pod queue

kubeovn · Apr 7, 2022 · 03af744 · 03af744
1 parent 0ea24dc
commit 03af744
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/pkg/controller/pod.go b/pkg/controller/pod.go
@@ -581,7 +581,7 @@ func (c *Controller) handleAddPod(key string) error {
 		if k8serrors.IsNotFound(err) {
 			// Sometimes pod is deleted between kube-ovn configure ovn-nb and patch pod.
 			// Then we need to recycle the resource again.
-			c.deletePodQueue.AddRateLimited(key)
+			c.deletePodQueue.AddRateLimited(pod)
 			return nil
 		}
 		klog.Errorf("patch pod %s/%s failed: %v", name, namespace, err)
@@ -907,7 +907,7 @@ func (c *Controller) handleUpdatePod(key string) error {
 		if k8serrors.IsNotFound(err) {
 			// Sometimes pod is deleted between kube-ovn configure ovn-nb and patch pod.
 			// Then we need to recycle the resource again.
-			c.deletePodQueue.AddRateLimited(key)
+			c.deletePodQueue.AddRateLimited(pod)
 			return nil
 		}
 		klog.Errorf("patch pod %s/%s failed %v", name, namespace, err)