From b0d6098a661c2c6bd9f932368dd7a036d67a1d83 Mon Sep 17 00:00:00 2001 From: Manuel de Brito Fontes Date: Wed, 20 Jun 2018 11:55:38 -0400 Subject: [PATCH] Remove unnecessary sync when the leader change --- internal/ingress/status/status.go | 6 ------ 1 file changed, 6 deletions(-) diff --git a/internal/ingress/status/status.go b/internal/ingress/status/status.go index 1622cbc35..6bb8556ba 100644 --- a/internal/ingress/status/status.go +++ b/internal/ingress/status/status.go @@ -32,7 +32,6 @@ import ( extensions "k8s.io/api/extensions/v1beta1" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "k8s.io/apimachinery/pkg/labels" - "k8s.io/apimachinery/pkg/util/wait" clientset "k8s.io/client-go/kubernetes" "k8s.io/client-go/kubernetes/scheme" "k8s.io/client-go/tools/leaderelection" @@ -183,11 +182,6 @@ 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) - wait.PollUntil(updateInterval, func() (bool, error) { - // send a dummy object to the queue to force a sync - st.syncQueue.Enqueue("sync status") - return false, nil - }, stop) }, OnStoppedLeading: func() { glog.V(2).Infof("I am not status update leader anymore")