Skip to content

Commit b90764f

Browse files
committed
feat: add support for jobs upgrade on standalone servers
1 parent 7a6077c commit b90764f

File tree

1 file changed

+18
-0
lines changed

1 file changed

+18
-0
lines changed

cluster/cluster_roll.go

Lines changed: 18 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -208,6 +208,24 @@ func (cluster *Cluster) RollingJobsUpgrade() error {
208208
cluster.LogModulePrintf(cluster.Conf.Verbose, config.ConstLogModGeneral, config.LvlInfo, "Jobs upgrade completed on %s ", s.URL)
209209
}
210210

211+
for _, s := range cluster.GetStandaloneServers() {
212+
ts = time.Now()
213+
s.SetWaitJobsUpgradeCookie()
214+
cluster.LogModulePrintf(cluster.Conf.Verbose, config.ConstLogModGeneral, config.LvlInfo, "Set jobs upgrade cookie on standalone %s ", s.URL)
215+
216+
// Wait for the server to clear the cookie
217+
for s.HasRollingJobsUpgradeCookie() {
218+
if time.Since(ts) > 5*time.Minute {
219+
cluster.LogModulePrintf(cluster.Conf.Verbose, config.ConstLogModGeneral, config.LvlErr, "Timeout waiting for jobs upgrade on standalone %s ", s.URL)
220+
return errors.New("Timeout waiting for jobs upgrade on standalone")
221+
}
222+
223+
time.Sleep(2 * time.Second)
224+
}
225+
226+
cluster.LogModulePrintf(cluster.Conf.Verbose, config.ConstLogModGeneral, config.LvlInfo, "Jobs upgrade completed on standalone %s ", s.URL)
227+
}
228+
211229
ts = time.Now()
212230
cluster.master.SetWaitJobsUpgradeCookie()
213231
cluster.LogModulePrintf(cluster.Conf.Verbose, config.ConstLogModGeneral, config.LvlInfo, "Set jobs upgrade cookie on master %s ", cluster.master.URL)

0 commit comments

Comments
 (0)