diff --git a/pkg/manager/internal.go b/pkg/manager/internal.go index 78202943f1..af4eb2d072 100644 --- a/pkg/manager/internal.go +++ b/pkg/manager/internal.go @@ -473,8 +473,8 @@ func (cm *controllerManager) Start(ctx context.Context) (err error) { } } else { // Treat not having leader election enabled the same as being elected. + cm.startLeaderElectionRunnables() close(cm.elected) - go cm.startLeaderElectionRunnables() } }() @@ -632,8 +632,8 @@ func (cm *controllerManager) startLeaderElection() (err error) { RetryPeriod: cm.retryPeriod, Callbacks: leaderelection.LeaderCallbacks{ OnStartedLeading: func(_ context.Context) { - close(cm.elected) cm.startLeaderElectionRunnables() + close(cm.elected) }, OnStoppedLeading: cm.onStoppedLeading, },