Merge pull request #2212 from zwtop/set_DeleteStateUnknown

🐛 Set DeleteStateUnknown when obj is DeletedFinalStateUnknown
kubernetes-sigs · Mar 1, 2023 · 69e67af · 69e67af
2 parents f6f37e6 + de8e46e
commit 69e67af
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 0 deletions.
diff --git a/pkg/internal/source/event_handler.go b/pkg/internal/source/event_handler.go
@@ -133,6 +133,9 @@ func (e *EventHandler) OnDelete(obj interface{}) {
 			return
 		}
 
+		// Set DeleteStateUnknown to true
+		d.DeleteStateUnknown = true
+
 		// Set obj to the tombstone obj
 		obj = tombstone.Obj
 	}

diff --git a/pkg/internal/source/internal_test.go b/pkg/internal/source/internal_test.go
@@ -269,6 +269,7 @@ var _ = Describe("Internal", func() {
 			funcs.DeleteFunc = func(ctx context.Context, evt event.DeleteEvent, q workqueue.RateLimitingInterface) {
 				defer GinkgoRecover()
 				Expect(evt.Object).To(Equal(pod))
+				Expect(evt.DeleteStateUnknown).Should(BeTrue())
 			}
 
 			instance.OnDelete(tombstone)