Test

aledbf · aledbf · commit 9ae5251b16a2 · 2023-08-17T08:45:50.000Z
diff --git a/components/ws-manager-mk2/main.go b/components/ws-manager-mk2/main.go
@@ -163,7 +163,7 @@ func main() {
 				now := time.Now()
 				setupLog.Info("updating activity started time", "now", now)
 				activity.ManagerStartedAt = now
-				time.Sleep(10 * time.Minute)
+				return
 			}
 		}
 	}()
@@ -217,6 +217,9 @@ func main() {
 		setupLog.Error(err, "problem running manager")
 		os.Exit(1)
 	}
+
+	setupLog.Info("new leader elected")
+	os.Exit(0)
 }
 
 func setupGRPCService(cfg *config.ServiceConfiguration, k8s client.Client, activity *activity.WorkspaceActivity, maintenance maintenance.Maintenance) (*service.WorkspaceManagerServer, error) {

Original file line number	Diff line number	Diff line change
`@@ -163,7 +163,7 @@ func main() {`
`163`	`163`	`now := time.Now()`
`164`	`164`	`setupLog.Info("updating activity started time", "now", now)`
`165`	`165`	`activity.ManagerStartedAt = now`
`166`		`- time.Sleep(10 * time.Minute)`
	`166`	`+ return`
`167`	`167`	`}`
`168`	`168`	`}`
`169`	`169`	`}()`
`@@ -217,6 +217,9 @@ func main() {`
`217`	`217`	`setupLog.Error(err, "problem running manager")`
`218`	`218`	`os.Exit(1)`
`219`	`219`	`}`
	`220`	`+`
	`221`	`+ setupLog.Info("new leader elected")`
	`222`	`+ os.Exit(0)`
`220`	`223`	`}`
`221`	`224`
`222`	`225`	`func setupGRPCService(cfg config.ServiceConfiguration, k8s client.Client, activity activity.WorkspaceActivity, maintenance maintenance.Maintenance) (*service.WorkspaceManagerServer, error) {`