summaryrefslogtreecommitdiffstats
path: root/node-repository/src/test
diff options
context:
space:
mode:
authorValerij Fredriksen <valerijf@yahooinc.com>2022-11-17 11:23:45 +0100
committerValerij Fredriksen <valerijf@yahooinc.com>2022-11-17 11:23:45 +0100
commit926e7ac56525833c1ff3750a4e49dc07f23378dc (patch)
tree097a935667433624a9de1c52df95c7c8f1dd7777 /node-repository/src/test
parent619f58b1f1e81aa073fb43d87a484f2cf0ffee34 (diff)
Retire nodes on wrong parent account
Diffstat (limited to 'node-repository/src/test')
-rw-r--r--node-repository/src/test/java/com/yahoo/vespa/hosted/provision/provisioning/DynamicProvisioningTest.java17
1 files changed, 8 insertions, 9 deletions
diff --git a/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/provisioning/DynamicProvisioningTest.java b/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/provisioning/DynamicProvisioningTest.java
index 53ce516c072..04b260b356d 100644
--- a/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/provisioning/DynamicProvisioningTest.java
+++ b/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/provisioning/DynamicProvisioningTest.java
@@ -284,7 +284,6 @@ public class DynamicProvisioningTest {
hostProvisioner.overrideHostFlavor("x86");
tester.activate(app, cluster, capacity);
NodeList nodes = tester.nodeRepository().nodes().list();
- nodes.forEach(n -> System.out.println(n.hostname() + " " + n.flavor().name()));
assertEquals(4, nodes.owner(app).state(Node.State.active).size());
assertEquals(Set.of("x86"), nodes.parentsOf(nodes.owner(app).state(Node.State.active)).stream().map(n -> n.flavor().name()).collect(Collectors.toSet()));
@@ -292,18 +291,18 @@ public class DynamicProvisioningTest {
flagSource.withStringFlag(PermanentFlags.HOST_FLAVOR.id(), "arm");
tester.activate(app, cluster, capacity);
nodes = tester.nodeRepository().nodes().list();
- assertEquals(4, nodes.owner(app).state(Node.State.inactive).size());
- assertEquals(4, nodes.owner(app).state(Node.State.active).size());
- assertEquals(Set.of("x86"), nodes.parentsOf(tester.getNodes(app, Node.State.inactive)).stream().map(n -> n.flavor().name()).collect(Collectors.toSet()));
- assertEquals(Set.of("arm"), nodes.parentsOf(tester.getNodes(app, Node.State.active)).stream().map(n -> n.flavor().name()).collect(Collectors.toSet()));
+ assertEquals(4, nodes.owner(app).state(Node.State.active).retired().size());
+ assertEquals(4, nodes.owner(app).state(Node.State.active).not().retired().size());
+ assertEquals(Set.of("x86"), nodes.parentsOf(tester.getNodes(app, Node.State.active).retired()).stream().map(n -> n.flavor().name()).collect(Collectors.toSet()));
+ assertEquals(Set.of("arm"), nodes.parentsOf(tester.getNodes(app, Node.State.active).not().retired()).stream().map(n -> n.flavor().name()).collect(Collectors.toSet()));
flagSource.removeFlag(PermanentFlags.HOST_FLAVOR.id()); // Resetting flag does not moves the nodes back
tester.activate(app, cluster, capacity);
nodes = tester.nodeRepository().nodes().list();
- assertEquals(4, nodes.owner(app).state(Node.State.inactive).size());
- assertEquals(4, nodes.owner(app).state(Node.State.active).size());
- assertEquals(Set.of("x86"), nodes.parentsOf(tester.getNodes(app, Node.State.inactive)).stream().map(n -> n.flavor().name()).collect(Collectors.toSet()));
- assertEquals(Set.of("arm"), nodes.parentsOf(tester.getNodes(app, Node.State.active)).stream().map(n -> n.flavor().name()).collect(Collectors.toSet()));
+ assertEquals(4, nodes.owner(app).state(Node.State.active).retired().size());
+ assertEquals(4, nodes.owner(app).state(Node.State.active).not().retired().size());
+ assertEquals(Set.of("x86"), nodes.parentsOf(tester.getNodes(app, Node.State.active).retired()).stream().map(n -> n.flavor().name()).collect(Collectors.toSet()));
+ assertEquals(Set.of("arm"), nodes.parentsOf(tester.getNodes(app, Node.State.active).not().retired()).stream().map(n -> n.flavor().name()).collect(Collectors.toSet()));
}
@Test