diff --git a/pkg/kube_events_manager/factory.go b/pkg/kube_events_manager/factory.go
index af3aa9bf..efbfa4c5 100644
--- a/pkg/kube_events_manager/factory.go
+++ b/pkg/kube_events_manager/factory.go
@@ -222,7 +222,7 @@ func (c *FactoryStore) WaitStopped(index FactoryIndex) {
 	ch, ok := c.stoppedCh[index]
 	if !ok {
 		ch = make(chan struct{})
-		c.stoppedCh[index] = ch
+		close(ch)
 	}
 
 	c.mu.Unlock()