Skip to content

Commit

Permalink
wip
Browse files Browse the repository at this point in the history
  • Loading branch information
Jorres committed Jan 22, 2025
1 parent 7a95777 commit f1b7cff
Show file tree
Hide file tree
Showing 4 changed files with 2,242 additions and 4 deletions.
4 changes: 2 additions & 2 deletions pkg/rolling/restart_handler.go
Original file line number Diff line number Diff line change
Expand Up @@ -89,9 +89,9 @@ func (rh *restartHandler) run() {
}
}

func (rh *restartHandler) stop(shouldWaitForDelay bool) {
func (rh *restartHandler) stop(waitForDelay bool) {
close(rh.queue)
if shouldWaitForDelay {
if waitForDelay {
rh.wg.Wait()
}
close(rh.done)
Expand Down
4 changes: 2 additions & 2 deletions pkg/rolling/rolling.go
Original file line number Diff line number Diff line change
Expand Up @@ -372,9 +372,9 @@ func (r *Rolling) processActionGroupStates(actions []*Ydb_Maintenance.ActionGrou
r.state.unreportedButFinishedActionIds = []string{}

restartCompleted := len(actions) == len(result.ActionStatuses)
shouldWaitForDelay := !restartCompleted
waitForDelay := !restartCompleted

restartHandler.stop(shouldWaitForDelay)
restartHandler.stop(waitForDelay)

return restartCompleted
}
Expand Down
4 changes: 4 additions & 0 deletions sammyvimes.txt
Original file line number Diff line number Diff line change
@@ -0,0 +1,4 @@
2024-12-25T18:13:51.105+0100 debug Current logging level enabled: debug
2024-12-25T18:13:51.105+0100 debug Authentication type not specified, implicitly assuming type: iam-token
2024-12-25T18:13:51.105+0100 info Start rolling restart
2024-12-25T18:13:51.105+0100 debug Invoke ListClusterNodes method
Loading

0 comments on commit f1b7cff

Please sign in to comment.