Skip to content

Commit 7154f39

Browse files
add item forgot
1 parent ce33f75 commit 7154f39

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

controller/controller.go

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -61,6 +61,8 @@ func (c *controller) processItem() bool {
6161
if shutdown {
6262
return false
6363
}
64+
// we do not process the item again
65+
defer c.queue.Forget(item)
6466
key, err := cache.MetaNamespaceKeyFunc(item)
6567
if err != nil {
6668
fmt.Printf("key and err, %s\n", err.Error())

0 commit comments

Comments
 (0)