diff options
-rw-r--r-- | node-repository/src/main/java/com/yahoo/vespa/hosted/provision/persistence/CuratorDb.java | 7 |
1 files changed, 2 insertions, 5 deletions
diff --git a/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/persistence/CuratorDb.java b/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/persistence/CuratorDb.java index a0d8aebc88e..74d88d4e73c 100644 --- a/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/persistence/CuratorDb.java +++ b/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/persistence/CuratorDb.java @@ -124,10 +124,7 @@ public class CuratorDb { byte[] serialized = nodeSerializer.toJson(node); curatorTransaction.add(CuratorOperations.create(nodePath(node).getAbsolute(), serialized)); } - - for (Node node : nodes) - log.log(Level.INFO, "Added " + node); - + transaction.onCommitted(() -> nodes.forEach(node -> log.log(Level.INFO, "Added " + node))); return nodes; } @@ -144,7 +141,7 @@ public class CuratorDb { CuratorTransaction curatorTransaction = db.newCuratorTransactionIn(transaction); curatorTransaction.add(CuratorOperations.delete(nodePath(node).getAbsolute())); } - nodes.forEach(node -> log.log(Level.INFO, "Removed node " + node.hostname() + " in state " + node.state())); + transaction.onCommitted(() -> nodes.forEach(node -> log.log(Level.INFO, "Removed node " + node.hostname() + " in state " + node.state()))); } /** |