fix: run healtcheck only on leader (#42)

castai · Sep 22, 2022 · e526c49 · e526c49
1 parent 8d3c7d2
commit e526c49
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 1 deletion.
diff --git a/actions/actions.go b/actions/actions.go
@@ -85,6 +85,7 @@ type service struct {
 }
 
 func (s *service) Run(ctx context.Context) {
+	s.healthCheck.Initializing()
 	for {
 		select {
 		case <-time.After(s.cfg.PollWaitInterval):

diff --git a/main.go b/main.go
@@ -141,7 +141,6 @@ func run(
 	}
 	healthzAction := health.NewHealthzProvider(health.HealthzCfg{HealthyPollIntervalLimit: (actionsConfig.PollWaitInterval + actionsConfig.PollTimeout) * 2}, log)
 
-	healthzAction.Initializing()
 	svc := actions.NewService(
 		log,
 		actionsConfig,