Skip to content

Commit 1b24414

Browse files
authored
[Bugfix] [1.2.33] Rotation fixes (#1415)
1 parent 50201bf commit 1b24414

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

pkg/deployment/reconcile/action_resign_leadership.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -165,9 +165,9 @@ func (a *actionResignLeadership) isServerRebooted(agencyState state.State, serve
165165
return false
166166
}
167167

168-
v, ok := a.actionCtx.Get(a.action, actionResignLeadershipRebootID)
168+
v, ok := a.action.Params[actionResignLeadershipRebootID.String()]
169169
if !ok {
170-
a.log.Warn("missing reboot ID in action's locals", v)
170+
a.log.Warn("missing reboot ID in action's locals")
171171
return false
172172
}
173173

pkg/deployment/reconcile/plan_builder_rotate_upgrade.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -222,7 +222,7 @@ func (r *Reconciler) createUpdatePlanInternal(apiObject k8sutil.APIObject, spec
222222
p = withWaitForMember(p, m.Group, m.Member)
223223

224224
p = append(p, actions.NewAction(api.ActionTypeArangoMemberUpdatePodStatus, m.Group, m.Member, "Propagating status of pod").AddParam(ActionTypeArangoMemberUpdatePodStatusChecksum, checksum))
225-
p.WrapWithPlan(api.Plan{
225+
p = p.WrapWithPlan(api.Plan{
226226
shared.RemoveMemberConditionActionV2(reason, api.ConditionTypePendingUpdate, m.Group, m.Member.ID),
227227
shared.UpdateMemberConditionActionV2(reason, api.ConditionTypeUpdating, m.Group, m.Member.ID, true, reason, "", ""),
228228
}, api.Plan{

0 commit comments

Comments
 (0)