From de6417e525666d9378fabb13947b24bff8f4775c Mon Sep 17 00:00:00 2001 From: sonjaer Date: Fri, 14 Jun 2024 14:34:35 +0200 Subject: [PATCH] fix error message (#299) Signed-off-by: Sonja Ericsson --- .../src/main/java/org/flyte/localengine/LocalEngine.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/flytekit-local-engine/src/main/java/org/flyte/localengine/LocalEngine.java b/flytekit-local-engine/src/main/java/org/flyte/localengine/LocalEngine.java index 86cb6b9a6..6aa4e2eff 100644 --- a/flytekit-local-engine/src/main/java/org/flyte/localengine/LocalEngine.java +++ b/flytekit-local-engine/src/main/java/org/flyte/localengine/LocalEngine.java @@ -102,7 +102,9 @@ private Map execute( Map previous = nodeOutputs.put(executionNode.nodeId(), outputs); if (previous != null) { - throw new IllegalStateException("invariant failed"); + throw new IllegalStateException( + String.format( + "invariant failed: node with same %s has already ran", executionNode.nodeId())); } executionListener.completed(executionNode, inputs, outputs);