Skip to content

Commit d52b185

Browse files
Merge pull request #351 from numtide/fix/drain-reload-sync-standby-config
⏺ fix(drain): reload pg config after sync standby removal
2 parents 63ec977 + 696f707 commit d52b185

File tree

1 file changed

+6
-4
lines changed

1 file changed

+6
-4
lines changed

pkg/data-handler/drain/drain.go

Lines changed: 6 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -156,8 +156,9 @@ func ExecuteDrainStateMachine(
156156
return true, nil
157157
} else {
158158
req := &multipoolermanagerdatapb.UpdateSynchronousStandbyListRequest{
159-
Operation: multipoolermanagerdatapb.StandbyUpdateOperation_STANDBY_UPDATE_OPERATION_REMOVE,
160-
StandbyIds: []*clustermetadatapb.ID{myPooler.Id},
159+
Operation: multipoolermanagerdatapb.StandbyUpdateOperation_STANDBY_UPDATE_OPERATION_REMOVE,
160+
StandbyIds: []*clustermetadatapb.ID{myPooler.Id},
161+
ReloadConfig: true,
161162
}
162163
_, rpcErr := rpcClient.UpdateSynchronousStandbyList(ctx, primary, req)
163164
if rpcErr != nil {
@@ -203,8 +204,9 @@ func ExecuteDrainStateMachine(
203204
return true, nil
204205
} else {
205206
req := &multipoolermanagerdatapb.UpdateSynchronousStandbyListRequest{
206-
Operation: multipoolermanagerdatapb.StandbyUpdateOperation_STANDBY_UPDATE_OPERATION_REMOVE,
207-
StandbyIds: []*clustermetadatapb.ID{myPooler.Id},
207+
Operation: multipoolermanagerdatapb.StandbyUpdateOperation_STANDBY_UPDATE_OPERATION_REMOVE,
208+
StandbyIds: []*clustermetadatapb.ID{myPooler.Id},
209+
ReloadConfig: true,
208210
}
209211
_, rpcErr := rpcClient.UpdateSynchronousStandbyList(ctx, primary, req)
210212
if rpcErr != nil {

0 commit comments

Comments
 (0)