fix adding key to delete Pod queue

kubeovn · Apr 7, 2022 · 6aa6b0a · 6aa6b0a
1 parent bf12ea0
commit 6aa6b0a
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/pkg/controller/pod.go b/pkg/controller/pod.go
@@ -527,7 +527,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)
@@ -811,7 +811,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)