diff options
author | Martin Polden <mpolden@mpolden.no> | 2022-07-07 16:37:43 +0200 |
---|---|---|
committer | Martin Polden <mpolden@mpolden.no> | 2022-07-08 09:07:19 +0200 |
commit | b849c9f421d7b0e062a7cc503a3ac3ad0782e320 (patch) | |
tree | 755158233b42e9c60fd9fb2b0d457942bf83063c /node-repository/src/test/java/com/yahoo/vespa/hosted/provision/os | |
parent | 47059d7888c9a278f2ccb038c2014b88cf6eda6a (diff) |
Limit grace period to RetiringOsUpgrader
Diffstat (limited to 'node-repository/src/test/java/com/yahoo/vespa/hosted/provision/os')
-rw-r--r-- | node-repository/src/test/java/com/yahoo/vespa/hosted/provision/os/OsVersionsTest.java | 20 |
1 files changed, 2 insertions, 18 deletions
diff --git a/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/os/OsVersionsTest.java b/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/os/OsVersionsTest.java index c3a5d7efd2f..af2a215dae0 100644 --- a/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/os/OsVersionsTest.java +++ b/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/os/OsVersionsTest.java @@ -65,13 +65,6 @@ public class OsVersionsTest { // Resume upgrade versions.resumeUpgradeOf(NodeType.host, true); NodeList allHosts = hostNodes.get(); - assertFalse("No upgrades of new hosts", allHosts.except(hostOnLaterVersion).stream() - .anyMatch(node -> node.status().osVersion().wanted().isPresent())); - - // Resume upgrade after sufficient time - tester.clock().advance(OsUpgrader.gracePeriod.plusDays(1)); - versions.resumeUpgradeOf(NodeType.host, true); - allHosts = hostNodes.get(); assertTrue("Wanted version is set", allHosts.except(hostOnLaterVersion).stream() .allMatch(node -> node.status().osVersion().wanted().isPresent())); assertTrue("Wanted version is not set for host on later version", @@ -106,8 +99,6 @@ public class OsVersionsTest { provisionInfraApplication(totalNodes); Supplier<NodeList> hostNodes = () -> tester.nodeRepository().nodes().list().state(Node.State.active).hosts(); - tester.clock().advance(OsUpgrader.gracePeriod.plusDays(1)); - // 5 nodes have no version. The other 15 are spread across different versions var hostNodesList = hostNodes.get().asList(); for (int i = totalNodes - maxActiveUpgrades - 1; i >= 0; i--) { @@ -153,7 +144,6 @@ public class OsVersionsTest { var versions = new OsVersions(tester.nodeRepository()); provisionInfraApplication(10); Supplier<NodeList> hostNodes = () -> tester.nodeRepository().nodes().list().hosts(); - tester.clock().advance(OsUpgrader.gracePeriod.plusDays(1)); // Some nodes are targeting an older version var version1 = Version.fromString("7.1"); @@ -182,7 +172,7 @@ public class OsVersionsTest { Supplier<NodeList> hostNodes = () -> tester.nodeRepository().nodes().list() .hosts() .not().state(Node.State.deprovisioned); - tester.clock().advance(OsUpgrader.gracePeriod.plusDays(1)); + tester.clock().advance(RetiringOsUpgrader.GRACE_PERIOD.plusDays(1)); // Target is set and upgrade started var version1 = Version.fromString("7.1"); @@ -244,7 +234,7 @@ public class OsVersionsTest { Supplier<NodeList> hostNodes = () -> tester.nodeRepository().nodes().list() .nodeType(NodeType.confighost) .not().state(Node.State.deprovisioned); - tester.clock().advance(OsUpgrader.gracePeriod.plusDays(1)); + tester.clock().advance(RetiringOsUpgrader.GRACE_PERIOD.plusDays(1)); // Target is set with zero budget and upgrade started var version1 = Version.fromString("7.1"); @@ -267,7 +257,6 @@ public class OsVersionsTest { int hostCount = 10; provisionInfraApplication(hostCount + 1); Supplier<NodeList> hostNodes = () -> tester.nodeRepository().nodes().list().nodeType(NodeType.host); - tester.clock().advance(OsUpgrader.gracePeriod.plusDays(1)); // All hosts upgrade to first version. Upgrades are delegated var version0 = Version.fromString("7.0"); @@ -315,7 +304,6 @@ public class OsVersionsTest { assertEquals(0, hostNodes.get().rebuilding().size()); // Next version is within same major. Upgrade mechanism switches to delegated - tester.clock().advance(OsUpgrader.gracePeriod.plusDays(1)); var version2 = Version.fromString("8.1"); versions.setTarget(NodeType.host, version2, Duration.ZERO, false); versions.resumeUpgradeOf(NodeType.host, true); @@ -346,8 +334,6 @@ public class OsVersionsTest { Supplier<NodeList> hosts = () -> tester.nodeRepository().nodes().list().nodeType(NodeType.host, NodeType.confighost); - tester.clock().advance(OsUpgrader.gracePeriod.plusDays(1)); - // All hosts upgrade to first version. Upgrades are delegated var version0 = Version.fromString("7.0"); versions.setTarget(NodeType.host, version0, Duration.ZERO, false); @@ -382,7 +368,6 @@ public class OsVersionsTest { deployApplication(app1); deployApplication(app2); Supplier<NodeList> hosts = () -> tester.nodeRepository().nodes().list().nodeType(NodeType.host); - tester.clock().advance(OsUpgrader.gracePeriod.plusDays(1)); // All hosts are on initial version var version0 = Version.fromString("7.0"); @@ -456,7 +441,6 @@ public class OsVersionsTest { var versions = new OsVersions(tester.nodeRepository(), false, Integer.MAX_VALUE); provisionInfraApplication(hostCount, infraApplication, NodeType.proxyhost); Supplier<NodeList> hosts = () -> tester.nodeRepository().nodes().list().nodeType(NodeType.proxyhost); - tester.clock().advance(OsUpgrader.gracePeriod.plusDays(1)); // All hosts are on initial version var version0 = Version.fromString("7.0"); |