diff --git a/pkg/internal/source/event_handler.go b/pkg/internal/source/event_handler.go index 8449a9dc75..7843135c08 100644 --- 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 index 9203879ac8..067753b9e0 100644 --- 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)