diff options
author | Valerij Fredriksen <valerijf@oath.com> | 2018-02-21 16:09:23 +0100 |
---|---|---|
committer | Valerij Fredriksen <valerijf@oath.com> | 2018-02-21 16:09:23 +0100 |
commit | 074f916a9ae8218d914f03be4d94c81ba8206096 (patch) | |
tree | 1931afec048ba6c20de755ea0b3b1b1777d307f9 /node-repository | |
parent | 98ec9c46c8422ac6eeea0c07f3b437769da688b8 (diff) |
Always set agent and reason for moving to dirty
Diffstat (limited to 'node-repository')
17 files changed, 45 insertions, 39 deletions
diff --git a/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/NodeRepository.java b/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/NodeRepository.java index 830eb249ecb..0420ee5d64e 100644 --- a/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/NodeRepository.java +++ b/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/NodeRepository.java @@ -12,7 +12,6 @@ import com.yahoo.config.provision.NodeFlavors; import com.yahoo.config.provision.NodeType; import com.yahoo.config.provision.Zone; import com.yahoo.config.provisioning.NodeRepositoryConfig; -import com.yahoo.path.Path; import com.yahoo.transaction.Mutex; import com.yahoo.transaction.NestedTransaction; import com.yahoo.vespa.curator.Curator; @@ -372,13 +371,8 @@ public class NodeRepository extends AbstractComponent { } /** Move nodes to the dirty state */ - public List<Node> setDirty(List<Node> nodes) { - return performOn(NodeListFilter.from(nodes), this::setDirty); - } - - /** Move a single node to the dirty state */ - public Node setDirty(Node node) { - return db.writeTo(Node.State.dirty, node, Agent.system, Optional.empty()); + public List<Node> setDirty(List<Node> nodes, Agent agent, String reason) { + return performOn(NodeListFilter.from(nodes), node -> setDirty(node, agent, reason)); } /** @@ -387,13 +381,18 @@ public class NodeRepository extends AbstractComponent { * * @throws IllegalArgumentException if the node has hardware failure */ - public Node setDirty(String hostname) { - Node nodeToDirty = getNode(hostname, Node.State.provisioned, Node.State.failed, Node.State.parked).orElseThrow(() -> + public Node setDirty(Node node, Agent agent, String reason) { + if (node.status().hardwareFailureDescription().isPresent()) + throw new IllegalArgumentException("Could not deallocate " + node.hostname() + ": It has a hardware failure"); + + return db.writeTo(Node.State.dirty, node, agent, Optional.of(reason)); + } + + public Node setDirty(String hostname, Agent agent, String reason) { + Node node = getNode(hostname, Node.State.provisioned, Node.State.failed, Node.State.parked).orElseThrow(() -> new IllegalArgumentException("Could not deallocate " + hostname + ": No such node in the provisioned, failed or parked state")); - if (nodeToDirty.status().hardwareFailureDescription().isPresent()) - throw new IllegalArgumentException("Could not deallocate " + hostname + ": It has a hardware failure"); - return setDirty(nodeToDirty); + return setDirty(node, agent, reason); } /** diff --git a/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/maintenance/FailedExpirer.java b/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/maintenance/FailedExpirer.java index 4ee56167c50..b2b20018418 100644 --- a/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/maintenance/FailedExpirer.java +++ b/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/maintenance/FailedExpirer.java @@ -111,7 +111,7 @@ public class FailedExpirer extends Maintainer { nodesToRecycle.add(candidate); } } - nodeRepository.setDirty(nodesToRecycle); + nodeRepository.setDirty(nodesToRecycle, Agent.system, "Expired by FailedExpirer"); } /** Returns whether the current node fail count should be used as an indicator of hardware issue */ diff --git a/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/maintenance/InactiveExpirer.java b/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/maintenance/InactiveExpirer.java index 4db807148e4..af0dc859d89 100644 --- a/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/maintenance/InactiveExpirer.java +++ b/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/maintenance/InactiveExpirer.java @@ -40,9 +40,9 @@ public class InactiveExpirer extends Expirer { protected void expire(List<Node> expired) { expired.forEach(node -> { if (node.status().wantToRetire()) { - nodeRepository.park(node.hostname(), Agent.system, "Parked by InactiveExpirer"); + nodeRepository.park(node.hostname(), Agent.system, "Expired by InactiveExpirer"); } else { - nodeRepository.setDirty(node); + nodeRepository.setDirty(node, Agent.system, "Expired by InactiveExprier"); } }); } diff --git a/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/maintenance/ReservationExpirer.java b/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/maintenance/ReservationExpirer.java index 6ba42c6db48..a99bd9e4ab9 100644 --- a/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/maintenance/ReservationExpirer.java +++ b/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/maintenance/ReservationExpirer.java @@ -3,6 +3,7 @@ package com.yahoo.vespa.hosted.provision.maintenance; import com.yahoo.vespa.hosted.provision.Node; import com.yahoo.vespa.hosted.provision.NodeRepository; +import com.yahoo.vespa.hosted.provision.node.Agent; import com.yahoo.vespa.hosted.provision.node.History; import java.time.Duration; @@ -29,6 +30,6 @@ public class ReservationExpirer extends Expirer { } @Override - protected void expire(List<Node> expired) { nodeRepository.setDirty(expired); } + protected void expire(List<Node> expired) { nodeRepository.setDirty(expired, Agent.system, "Expired by ReservationExpirer"); } } diff --git a/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/restapi/v2/NodesApiHandler.java b/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/restapi/v2/NodesApiHandler.java index b188ae7fb20..0371cfec337 100644 --- a/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/restapi/v2/NodesApiHandler.java +++ b/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/restapi/v2/NodesApiHandler.java @@ -122,7 +122,7 @@ public class NodesApiHandler extends LoggingRequestHandler { return new MessageResponse("Moved " + parkedHostnames + " to parked"); } else if (path.startsWith("/nodes/v2/state/dirty/")) { - nodeRepository.setDirty(lastElement(path)); + nodeRepository.setDirty(lastElement(path), Agent.operator, "Dirtied through the nodes/v2 API"); return new MessageResponse("Moved " + lastElement(path) + " to dirty"); } else if (path.startsWith("/nodes/v2/state/active/")) { diff --git a/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/testutils/MockNodeRepository.java b/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/testutils/MockNodeRepository.java index 96916671888..7af28efd293 100644 --- a/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/testutils/MockNodeRepository.java +++ b/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/testutils/MockNodeRepository.java @@ -103,11 +103,11 @@ public class MockNodeRepository extends NodeRepository { nodes = addNodes(nodes); nodes.remove(6); nodes.remove(7); - nodes = setDirty(nodes); + nodes = setDirty(nodes, Agent.system, getClass().getSimpleName()); setReady(nodes); - fail("host5.yahoo.com", Agent.system, "Failing to unit test"); - setDirty("host55.yahoo.com"); + fail("host5.yahoo.com", Agent.system, getClass().getSimpleName()); + setDirty("host55.yahoo.com", Agent.system, getClass().getSimpleName()); ApplicationId zoneApp = ApplicationId.from(TenantName.from("zoneapp"), ApplicationName.from("zoneapp"), InstanceName.from("zoneapp")); ClusterSpec zoneCluster = ClusterSpec.request(ClusterSpec.Type.container, diff --git a/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/NodeRepositoryTest.java b/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/NodeRepositoryTest.java index dce256c67f4..86d43c25011 100644 --- a/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/NodeRepositoryTest.java +++ b/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/NodeRepositoryTest.java @@ -72,7 +72,7 @@ public class NodeRepositoryTest { // Expected } - tester.nodeRepository().setDirty("host1"); + tester.nodeRepository().setDirty("host1", Agent.system, getClass().getSimpleName()); tester.nodeRepository().setReady("host1"); tester.nodeRepository().removeRecursively("host1"); } @@ -89,7 +89,7 @@ public class NodeRepositoryTest { tester.addNode("node20", "node20", "host2", "docker", NodeType.tenant); assertEquals(6, tester.nodeRepository().getNodes().size()); - tester.nodeRepository().setDirty("node11"); + tester.nodeRepository().setDirty("node11", Agent.system, getClass().getSimpleName()); try { tester.nodeRepository().removeRecursively("host1"); diff --git a/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/maintenance/FailedExpirerTest.java b/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/maintenance/FailedExpirerTest.java index c3c32f2decb..7151006d743 100644 --- a/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/maintenance/FailedExpirerTest.java +++ b/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/maintenance/FailedExpirerTest.java @@ -276,7 +276,7 @@ public class FailedExpirerTest { List<Node> nodes = Stream.of(hostname) .map(this::get) .collect(Collectors.toList()); - nodeRepository.setReady(nodeRepository.setDirty(nodes)); + nodeRepository.setReady(nodeRepository.setDirty(nodes, Agent.system, getClass().getSimpleName())); return this; } diff --git a/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/maintenance/MaintenanceTester.java b/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/maintenance/MaintenanceTester.java index 4dec3f9bde5..e3fb2115fb1 100644 --- a/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/maintenance/MaintenanceTester.java +++ b/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/maintenance/MaintenanceTester.java @@ -12,6 +12,7 @@ import com.yahoo.vespa.curator.Curator; import com.yahoo.vespa.curator.mock.MockCurator; import com.yahoo.vespa.hosted.provision.Node; import com.yahoo.vespa.hosted.provision.NodeRepository; +import com.yahoo.vespa.hosted.provision.node.Agent; import com.yahoo.vespa.hosted.provision.provisioning.FlavorConfigBuilder; import com.yahoo.vespa.hosted.provision.testutils.MockNameResolver; @@ -43,7 +44,7 @@ public class MaintenanceTester { for (int i = 0; i < count; i++) nodes.add(nodeRepository.createNode("node" + i, "host" + i, Optional.empty(), nodeFlavors.getFlavorOrThrow("default"), NodeType.tenant)); nodes = nodeRepository.addNodes(nodes); - nodes = nodeRepository.setDirty(nodes); + nodes = nodeRepository.setDirty(nodes, Agent.system, getClass().getSimpleName()); nodes = simulateInitialReboot(nodes); nodeRepository.setReady(nodes); } @@ -53,7 +54,7 @@ public class MaintenanceTester { for (int i = 0; i < count; i++) nodes.add(nodeRepository.createNode("hostNode" + i, "realHost" + i, Optional.empty(), nodeFlavors.getFlavorOrThrow("default"), NodeType.host)); nodes = nodeRepository.addNodes(nodes); - nodes = nodeRepository.setDirty(nodes); + nodes = nodeRepository.setDirty(nodes, Agent.system, getClass().getSimpleName()); nodes = simulateInitialReboot(nodes); nodeRepository.setReady(nodes); } diff --git a/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/maintenance/NodeFailTester.java b/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/maintenance/NodeFailTester.java index 1d51fc47462..ff4403842f2 100644 --- a/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/maintenance/NodeFailTester.java +++ b/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/maintenance/NodeFailTester.java @@ -24,6 +24,7 @@ import com.yahoo.vespa.curator.transaction.CuratorTransaction; import com.yahoo.vespa.hosted.provision.Node; import com.yahoo.vespa.hosted.provision.NodeRepository; import com.yahoo.vespa.hosted.provision.monitoring.MetricsReporterTest; +import com.yahoo.vespa.hosted.provision.node.Agent; import com.yahoo.vespa.hosted.provision.provisioning.FlavorConfigBuilder; import com.yahoo.vespa.hosted.provision.provisioning.NodeRepositoryProvisioner; import com.yahoo.vespa.hosted.provision.testutils.MockDeployer; @@ -219,7 +220,7 @@ public class NodeFailTester { nodes.add(nodeRepository.createNode("node" + i, "host" + i, parentHostname, flavor, nodeType)); nodes = nodeRepository.addNodes(nodes); - nodes = nodeRepository.setDirty(nodes); + nodes = nodeRepository.setDirty(nodes, Agent.system, getClass().getSimpleName()); return nodeRepository.setReady(nodes); } @@ -228,7 +229,7 @@ public class NodeFailTester { for (int i = 0; i < count; i++) nodes.add(nodeRepository.createNode("parent" + i, "parent" + i, Optional.empty(), nodeFlavors.getFlavorOrThrow("default"), NodeType.host)); nodes = nodeRepository.addNodes(nodes); - nodes = nodeRepository.setDirty(nodes); + nodes = nodeRepository.setDirty(nodes, Agent.system, getClass().getSimpleName()); return nodeRepository.setReady(nodes); } diff --git a/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/maintenance/NodeRetirerTester.java b/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/maintenance/NodeRetirerTester.java index 3b9bf498869..392d3e2a5c9 100644 --- a/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/maintenance/NodeRetirerTester.java +++ b/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/maintenance/NodeRetirerTester.java @@ -18,6 +18,7 @@ import com.yahoo.vespa.curator.mock.MockCurator; import com.yahoo.vespa.hosted.provision.Node; import com.yahoo.vespa.hosted.provision.NodeRepository; import com.yahoo.vespa.hosted.provision.maintenance.retire.RetirementPolicy; +import com.yahoo.vespa.hosted.provision.node.Agent; import com.yahoo.vespa.hosted.provision.provisioning.FlavorConfigBuilder; import com.yahoo.vespa.hosted.provision.provisioning.FlavorSpareChecker; import com.yahoo.vespa.hosted.provision.provisioning.NodeRepositoryProvisioner; @@ -100,7 +101,7 @@ public class NodeRetirerTester { } nodes = nodeRepository.addNodes(nodes); - nodes = nodeRepository.setDirty(nodes); + nodes = nodeRepository.setDirty(nodes, Agent.system, getClass().getSimpleName()); nodeRepository.setReady(nodes); } diff --git a/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/maintenance/OperatorChangeApplicationMaintainerTest.java b/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/maintenance/OperatorChangeApplicationMaintainerTest.java index d2ec5865a0c..629d4187065 100644 --- a/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/maintenance/OperatorChangeApplicationMaintainerTest.java +++ b/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/maintenance/OperatorChangeApplicationMaintainerTest.java @@ -91,7 +91,7 @@ public class OperatorChangeApplicationMaintainerTest { for (int i = 0; i < count; i++) nodes.add(nodeRepository.createNode("node" + i, "host" + i, Optional.empty(), nodeFlavors.getFlavorOrThrow("default"), NodeType.tenant)); nodes = nodeRepository.addNodes(nodes); - nodes = nodeRepository.setDirty(nodes); + nodes = nodeRepository.setDirty(nodes, Agent.system, getClass().getSimpleName()); nodeRepository.setReady(nodes); } @@ -100,7 +100,7 @@ public class OperatorChangeApplicationMaintainerTest { for (int i = 0; i < count; i++) nodes.add(nodeRepository.createNode("hostNode" + i, "realHost" + i, Optional.empty(), nodeFlavors.getFlavorOrThrow("default"), NodeType.host)); nodes = nodeRepository.addNodes(nodes); - nodes = nodeRepository.setDirty(nodes); + nodes = nodeRepository.setDirty(nodes, Agent.system, getClass().getSimpleName()); nodeRepository.setReady(nodes); } diff --git a/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/maintenance/PeriodicApplicationMaintainerTest.java b/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/maintenance/PeriodicApplicationMaintainerTest.java index d9a6b62bbe9..8eec5e4c2f1 100644 --- a/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/maintenance/PeriodicApplicationMaintainerTest.java +++ b/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/maintenance/PeriodicApplicationMaintainerTest.java @@ -133,7 +133,7 @@ public class PeriodicApplicationMaintainerTest { for (int i = 0; i < count; i++) nodes.add(nodeRepository.createNode("node" + i, "host" + i, Optional.empty(), nodeFlavors.getFlavorOrThrow("default"), NodeType.tenant)); nodes = nodeRepository.addNodes(nodes); - nodes = nodeRepository.setDirty(nodes); + nodes = nodeRepository.setDirty(nodes, Agent.system, getClass().getSimpleName()); nodeRepository.setReady(nodes); } @@ -142,7 +142,7 @@ public class PeriodicApplicationMaintainerTest { for (int i = 0; i < count; i++) nodes.add(nodeRepository.createNode("hostNode" + i, "realHost" + i, Optional.empty(), nodeFlavors.getFlavorOrThrow("default"), NodeType.host)); nodes = nodeRepository.addNodes(nodes); - nodes = nodeRepository.setDirty(nodes); + nodes = nodeRepository.setDirty(nodes, Agent.system, getClass().getSimpleName()); nodeRepository.setReady(nodes); } diff --git a/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/maintenance/ReservationExpirerTest.java b/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/maintenance/ReservationExpirerTest.java index d5cd2870b31..6cbb512f489 100644 --- a/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/maintenance/ReservationExpirerTest.java +++ b/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/maintenance/ReservationExpirerTest.java @@ -14,6 +14,7 @@ import com.yahoo.vespa.curator.Curator; import com.yahoo.vespa.curator.mock.MockCurator; import com.yahoo.vespa.hosted.provision.Node; import com.yahoo.vespa.hosted.provision.NodeRepository; +import com.yahoo.vespa.hosted.provision.node.Agent; import com.yahoo.vespa.hosted.provision.provisioning.FlavorConfigBuilder; import com.yahoo.vespa.hosted.provision.provisioning.NodeRepositoryProvisioner; import com.yahoo.vespa.hosted.provision.testutils.MockNameResolver; @@ -49,7 +50,7 @@ public class ReservationExpirerTest { nodes.add(nodeRepository.createNode(UUID.randomUUID().toString(), UUID.randomUUID().toString(), Optional.empty(), flavors.getFlavorOrThrow("default"), NodeType.tenant)); nodes.add(nodeRepository.createNode(UUID.randomUUID().toString(), UUID.randomUUID().toString(), Optional.empty(), flavors.getFlavorOrThrow("default"), NodeType.host)); nodes = nodeRepository.addNodes(nodes); - nodes = nodeRepository.setDirty(nodes); + nodes = nodeRepository.setDirty(nodes, Agent.system, getClass().getSimpleName()); // Reserve 2 nodes assertEquals(2, nodeRepository.getNodes(NodeType.tenant, Node.State.dirty).size()); diff --git a/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/maintenance/RetiredExpirerTest.java b/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/maintenance/RetiredExpirerTest.java index 857385a9b77..0a2d1b59cb4 100644 --- a/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/maintenance/RetiredExpirerTest.java +++ b/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/maintenance/RetiredExpirerTest.java @@ -23,6 +23,7 @@ import com.yahoo.vespa.curator.mock.MockCurator; import com.yahoo.vespa.curator.transaction.CuratorTransaction; import com.yahoo.vespa.hosted.provision.Node; import com.yahoo.vespa.hosted.provision.NodeRepository; +import com.yahoo.vespa.hosted.provision.node.Agent; import com.yahoo.vespa.hosted.provision.provisioning.FlavorConfigBuilder; import com.yahoo.vespa.hosted.provision.provisioning.NodeRepositoryProvisioner; import com.yahoo.vespa.hosted.provision.testutils.MockDeployer; @@ -200,7 +201,7 @@ public class RetiredExpirerTest { for (int i = 0; i < count; i++) nodes.add(nodeRepository.createNode("node" + i, "node" + i, Optional.empty(), nodeFlavors.getFlavorOrThrow("default"), NodeType.tenant)); nodes = nodeRepository.addNodes(nodes); - nodes = nodeRepository.setDirty(nodes); + nodes = nodeRepository.setDirty(nodes, Agent.system, getClass().getSimpleName()); nodeRepository.setReady(nodes); } @@ -209,7 +210,7 @@ public class RetiredExpirerTest { for (int i = 0; i < count; i++) nodes.add(nodeRepository.createNode("parent" + i, "parent" + i, Optional.empty(), nodeFlavors.getFlavorOrThrow("default"), NodeType.host)); nodes = nodeRepository.addNodes(nodes); - nodes = nodeRepository.setDirty(nodes); + nodes = nodeRepository.setDirty(nodes, Agent.system, getClass().getSimpleName()); nodeRepository.setReady(nodes); } diff --git a/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/monitoring/MetricsReporterTest.java b/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/monitoring/MetricsReporterTest.java index d1a14d3e489..8fa63c49159 100644 --- a/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/monitoring/MetricsReporterTest.java +++ b/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/monitoring/MetricsReporterTest.java @@ -15,6 +15,7 @@ import com.yahoo.vespa.hosted.provision.Node; import com.yahoo.vespa.hosted.provision.NodeRepository; import com.yahoo.vespa.hosted.provision.maintenance.JobControl; import com.yahoo.vespa.hosted.provision.maintenance.MetricsReporter; +import com.yahoo.vespa.hosted.provision.node.Agent; import com.yahoo.vespa.hosted.provision.node.Allocation; import com.yahoo.vespa.hosted.provision.node.Generation; import com.yahoo.vespa.hosted.provision.provisioning.FlavorConfigBuilder; @@ -122,7 +123,7 @@ public class MetricsReporterTest { Node dockerHost = Node.create("openStackId1", Collections.singleton("::1"), additionalIps, "dockerHost", Optional.empty(), nodeFlavors.getFlavorOrThrow("host"), NodeType.host); nodeRepository.addNodes(Collections.singletonList(dockerHost)); - nodeRepository.setDirty("dockerHost"); + nodeRepository.setDirty("dockerHost", Agent.system, getClass().getSimpleName()); nodeRepository.setReady("dockerHost"); Node container1 = Node.createDockerNode("openStackId1:1", Collections.singleton("::2"), Collections.emptySet(), "container1", Optional.of("dockerHost"), nodeFlavors.getFlavorOrThrow("docker"), NodeType.tenant); diff --git a/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/provisioning/ProvisioningTester.java b/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/provisioning/ProvisioningTester.java index ffd98cc6a1a..2b50af91656 100644 --- a/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/provisioning/ProvisioningTester.java +++ b/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/provisioning/ProvisioningTester.java @@ -284,7 +284,7 @@ public class ProvisioningTester implements AutoCloseable { List<Node> makeReadyNodes(int n, String flavor, NodeType type, int additionalIps) { List<Node> nodes = makeProvisionedNodes(n, flavor, type, additionalIps); - nodes = nodeRepository.setDirty(nodes); + nodes = nodeRepository.setDirty(nodes, Agent.system, getClass().getSimpleName()); return nodeRepository.setReady(nodes); } @@ -302,7 +302,7 @@ public class ProvisioningTester implements AutoCloseable { nodeFlavors.getFlavorOrThrow(flavor), NodeType.tenant)); } nodes = nodeRepository.addNodes(nodes); - nodes = nodeRepository.setDirty(nodes); + nodes = nodeRepository.setDirty(nodes, Agent.system, getClass().getSimpleName()); nodeRepository.setReady(nodes); return nodes; } |