diff options
author | Ola Aunrønning <olaa@verizonmedia.com> | 2021-08-06 11:09:54 +0200 |
---|---|---|
committer | Ola Aunrønning <olaa@verizonmedia.com> | 2021-08-06 11:09:54 +0200 |
commit | d9aa1773fdde262c0b100f25de292bfcc7d23558 (patch) | |
tree | 9f62685b96a19ce7c84c95cd53d1d84c7d802a77 | |
parent | d4751f0bec0143b61dd033d7254b7c8ee5c4ce1e (diff) |
Only main controllers approve cmrs. Log approval
-rw-r--r-- | controller-server/src/main/java/com/yahoo/vespa/hosted/controller/maintenance/ChangeRequestMaintainer.java | 7 |
1 files changed, 6 insertions, 1 deletions
diff --git a/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/maintenance/ChangeRequestMaintainer.java b/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/maintenance/ChangeRequestMaintainer.java index 59156b62b96..46dba064a95 100644 --- a/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/maintenance/ChangeRequestMaintainer.java +++ b/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/maintenance/ChangeRequestMaintainer.java @@ -34,12 +34,14 @@ public class ChangeRequestMaintainer extends ControllerMaintainer { private final ChangeRequestClient changeRequestClient; private final CuratorDb curator; private final NodeRepository nodeRepository; + private final SystemName system; public ChangeRequestMaintainer(Controller controller, Duration interval) { super(controller, interval, null, SystemName.allOf(Predicate.not(SystemName::isPublic))); this.changeRequestClient = controller.serviceRegistry().changeRequestClient(); this.curator = controller.curator(); this.nodeRepository = controller.serviceRegistry().configServer().nodeRepository(); + this.system = controller.system(); } @@ -124,7 +126,10 @@ public class ChangeRequestMaintainer extends ControllerMaintainer { } private void approveChangeRequest(ChangeRequest changeRequest) { - if (changeRequest.getApproval() == ChangeRequest.Approval.REQUESTED) + if (system.equals(SystemName.main) && + changeRequest.getApproval() == ChangeRequest.Approval.REQUESTED) { + logger.info("Approving " + changeRequest.getChangeRequestSource().getId()); changeRequestClient.approveChangeRequest(changeRequest); + } } } |