diff --git a/internal/ingress/status/status.go b/internal/ingress/status/status.go index 5b58f96ca..acf802b34 100644 --- a/internal/ingress/status/status.go +++ b/internal/ingress/status/status.go @@ -183,8 +183,9 @@ func NewStatusSyncer(config Config) Sync { OnStartedLeading: func(stop <-chan struct{}) { glog.V(2).Infof("I am the new status update leader") go st.syncQueue.Run(time.Second, stop) + // when this instance is the leader we need to enqueue + // an item to trigger the update of the Ingress status. wait.PollUntil(updateInterval, func() (bool, error) { - // send a dummy object to the queue to force a sync st.syncQueue.EnqueueTask(task.GetDummyObject("sync status")) return false, nil }, stop)