runtimev2: error message for process arguments evaluation

runtime/v2/runner-test/src/test/java/com/walmartlabs/concord/runtime/v2/runner/LogExceptionsTest.java

@@ -278,4 +278,32 @@ public void noStacktraceForUserDefinedExceptionFromTaskParallelParallel() throws
         assertNoLog(runtime.lastLog(), ".*" + quote("com.walmartlabs.concord.svm.ParallelExecutionException") + ".*");
         assertNoLog(runtime.lastLog(), ".*" + quote("at com.walmartlabs.concord.runtime.v2.runner.vm.JoinCommand.execute") + ".*");
     }
+
+
+    @Test
+    public void noStackTraceForArgsEvalError() throws Exception {
+        runtime.deploy("logExceptionTests/invalidArgs");
+
+        runtime.save(ProcessConfiguration.builder()
+                .putArguments("name", "${undefinedVariableName}")
+                .build());
+
+        try {
+            runtime.run();
+            fail("Exception expected");
+        } catch (Exception e) {
+            // ignore
+        }
+
+        var errorMessage = "[ERROR] Error while evaluating process arguments: while evaluating expression " +
+                "'${undefinedVariableName}': Can't find a variable 'undefinedVariableName'. " +
+                "Check if it is defined in the current scope. " +
+                "Details: ELResolver cannot handle a null base Object with identifier 'undefinedVariableName'";
+
+        // error
+        assertLog(runtime.lastLog(), ".*" + quote(errorMessage) + ".*");
+
+        // no stacktrace
+        assertNoLog(runtime.lastLog(), ".*" + quote("at com.walmartlabs.concord.runtime.v2") + ".*");
+    }
 }

runtime/v2/runner-test/src/test/resources/com/walmartlabs/concord/runtime/v2/runner/logExceptionTests/invalidArgs/concord.yaml

@@ -0,0 +1,3 @@
+flows:
+  default:
+    - log: "OK"

runtime/v2/runner/src/main/java/com/walmartlabs/concord/runtime/v2/runner/Runner.java

@@ -79,7 +79,12 @@ public ProcessSnapshot start(ProcessConfiguration processConfiguration, ProcessD
 
         VM vm = createVM(processDefinition);
         // update the global variables using the input map by running a special command
-        vm.run(state, new UpdateLocalsCommand(input)); // TODO merge with the cfg's arguments
+        try {
+            vm.run(state, new UpdateLocalsCommand(input)); // TODO merge with the cfg's arguments
+        } catch (RuntimeException e) {
+            log.error("Error while evaluating process arguments: {}", e.getMessage(), e);
+            throw e;
+        }
         // start the normal execution
         vm.start(state);
 
@@ -105,7 +110,12 @@ public ProcessSnapshot resume(ProcessSnapshot snapshot, Set<String> eventRefs, M
                 .filter(kv -> eventRefs.contains(kv.getValue()))
                 .map(Map.Entry::getKey)
                 .collect(Collectors.toList());
-        vm.run(state, new UpdateLocalsCommand(input, resumingThreads));
+        try {
+            vm.run(state, new UpdateLocalsCommand(input, resumingThreads));
+        } catch (RuntimeException e) {
+            log.error("Error while evaluating resume arguments: {}", e.getMessage(), e);
+            throw e;
+        }
 
         // resume normally
         vm.resume(state, eventRefs);
@@ -126,7 +136,13 @@ public ProcessSnapshot resume(ProcessSnapshot snapshot, Map<String, Object> inpu
 
         VM vm = createVM(snapshot.processDefinition());
         // update the global variables using the input map by running a special command
-        vm.run(state, new UpdateLocalsCommand(input));
+        try {
+            vm.run(state, new UpdateLocalsCommand(input));
+        } catch (RuntimeException e) {
+            log.error("Error while evaluating resume arguments: {}", e.getMessage(), e);
+            throw e;
+        }
+
         // continue as usual
         vm.start(state);