diff options
author | Martin Polden <mpolden@mpolden.no> | 2022-07-12 10:34:57 +0200 |
---|---|---|
committer | Martin Polden <mpolden@mpolden.no> | 2022-07-12 10:34:57 +0200 |
commit | d01c10d78f8ef2cb8d31a31220a5ffd9beae0ee3 (patch) | |
tree | f2d0efe1dd9a9d9fcb19f569c068b8f8e5314fd4 /node-repository/src/test/java/com/yahoo | |
parent | 3e4ec608f84cdb73b394b4d468e5d575016b51d7 (diff) |
Node with allocation must be parked to allow deprovisioning
Diffstat (limited to 'node-repository/src/test/java/com/yahoo')
-rw-r--r-- | node-repository/src/test/java/com/yahoo/vespa/hosted/provision/maintenance/DynamicProvisioningMaintainerTest.java | 26 |
1 files changed, 19 insertions, 7 deletions
diff --git a/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/maintenance/DynamicProvisioningMaintainerTest.java b/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/maintenance/DynamicProvisioningMaintainerTest.java index 7f4171ee8c0..8b363881fde 100644 --- a/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/maintenance/DynamicProvisioningMaintainerTest.java +++ b/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/maintenance/DynamicProvisioningMaintainerTest.java @@ -576,17 +576,29 @@ public class DynamicProvisioningMaintainerTest { tester.hostProvisioner.with(Behaviour.failProvisioning); Node host4 = tester.addNode("host4", Optional.empty(), NodeType.host, Node.State.parked); Node host41 = tester.addNode("host4-1", Optional.of("host4"), NodeType.tenant, Node.State.parked, DynamicProvisioningTester.tenantApp); - tester.nodeRepository.nodes().deprovision("host4", Agent.operator, Instant.now()); + Node host42 = tester.addNode("host4-2", Optional.of("host4"), NodeType.tenant, Node.State.active, DynamicProvisioningTester.tenantApp); - assertEquals(Optional.of(true), tester.nodeRepository.nodes().node("host4").map(n -> n.status().wantToDeprovision())); - assertEquals(Optional.of(Node.State.parked), tester.nodeRepository.nodes().node("host4").map(Node::state)); - assertEquals(Optional.of(true), tester.nodeRepository.nodes().node("host4-1").map(n -> n.status().wantToDeprovision())); - assertEquals(Optional.of(Node.State.parked), tester.nodeRepository.nodes().node("host4-1").map(Node::state)); + // Host and children are marked for deprovisioning + tester.nodeRepository.nodes().deprovision("host4", Agent.operator, Instant.now()); + for (var node : List.of(host4, host41, host42)) { + assertTrue(tester.nodeRepository.nodes().node(node.hostname()).map(n -> n.status().wantToDeprovision()).get()); + } + // Host and children remain parked because one child is still active tester.maintainer.maintain(); + for (var node : List.of(host4, host41)) { + assertEquals(Node.State.parked, tester.nodeRepository.nodes().node(node.hostname()).get().state()); + } + assertEquals(Node.State.active, tester.nodeRepository.nodes().node(host42.hostname()).get().state()); - assertEquals(Optional.empty(), tester.nodeRepository.nodes().node("host4")); - assertEquals(Optional.empty(), tester.nodeRepository.nodes().node("host4-1")); + // Last child is parked + tester.nodeRepository.nodes().park(host42.hostname(), true, Agent.system, getClass().getSimpleName()); + + // Host and children can now be removed + tester.maintainer.maintain(); + for (var node : List.of(host4, host41, host42)) { + assertTrue(node.hostname() + " removed", tester.nodeRepository.nodes().node(node.hostname()).isEmpty()); + } } private void assertCfghost3IsActive(DynamicProvisioningTester tester) { |