We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 41678ed commit 740ab42Copy full SHA for 740ab42
internal/mode/static/manager.go
@@ -262,6 +262,10 @@ func StartManager(cfg config.Config) error {
262
return fmt.Errorf("cannot register event loop: %w", err)
263
}
264
265
+ if err = mgr.Add(runnables.NewEnableAfterBecameLeader(groupStatusUpdater.Enable)); err != nil {
266
+ return fmt.Errorf("cannot register status updater: %w", err)
267
+ }
268
+
269
if cfg.ProductTelemetryConfig.Enabled {
270
dataCollector := telemetry.NewDataCollectorImpl(telemetry.DataCollectorConfig{
271
K8sClientReader: mgr.GetAPIReader(),
0 commit comments