fix error message (#299)

Signed-off-by: Sonja Ericsson <[email protected]>
flyteorg · Jun 14, 2024 · de6417e · de6417e
1 parent c58d748
commit de6417e
Showing 1 changed file with 3 additions and 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
@@ -102,7 +102,9 @@ private Map<String, Literal> execute(
     Map<String, Literal> 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);