Skip to content

Commit 7847cd5

Browse files
committed
Wait before updating the activity started time
1 parent 6beecda commit 7847cd5

File tree

1 file changed

+9
-5
lines changed

1 file changed

+9
-5
lines changed

components/ws-manager-mk2/main.go

Lines changed: 9 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -156,8 +156,15 @@ func main() {
156156

157157
go func() {
158158
for {
159-
<-mgr.Elected()
160-
activity.ManagerStartedAt = time.Now()
159+
select {
160+
case <-mgrCtx.Done():
161+
return
162+
case <-mgr.Elected():
163+
now := time.Now()
164+
setupLog.Info("updating activity started time", "now", now)
165+
activity.ManagerStartedAt = now
166+
return
167+
}
161168
}
162169
}()
163170

@@ -210,9 +217,6 @@ func main() {
210217
setupLog.Error(err, "problem running manager")
211218
os.Exit(1)
212219
}
213-
214-
setupLog.Info("new leader elected")
215-
os.Exit(1)
216220
}
217221

218222
func setupGRPCService(cfg *config.ServiceConfiguration, k8s client.Client, activity *activity.WorkspaceActivity, maintenance maintenance.Maintenance) (*service.WorkspaceManagerServer, error) {

0 commit comments

Comments
 (0)