From de8e46e8c8077902948972919d570bd32905c6a5 Mon Sep 17 00:00:00 2001 From: zwtop Date: Mon, 27 Feb 2023 14:07:01 +0800 Subject: [PATCH] fix: set DeleteStateUnknown when obj is DeletedFinalStateUnknown Signed-off-by: zwtop --- pkg/internal/source/event_handler.go | 3 +++ pkg/internal/source/internal_test.go | 1 + 2 files changed, 4 insertions(+) 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)