diff --git a/common/src/main/java/org/opensearch/ml/common/utils/StringUtils.java b/common/src/main/java/org/opensearch/ml/common/utils/StringUtils.java
index 22165c487f..b70b7a1027 100644
--- a/common/src/main/java/org/opensearch/ml/common/utils/StringUtils.java
+++ b/common/src/main/java/org/opensearch/ml/common/utils/StringUtils.java
@@ -139,11 +139,16 @@ public static boolean isJson(String json) {
      *   prepareJsonValue("{\"key\":123}") → {\"key\":123} (valid JSON object, unchanged)
      * </pre>
      * @param input
+     * @param escapeJson
      * @return
      */
-    public static String prepareJsonValue(String input) {
+    public static String prepareJsonValue(String input, boolean escapeJson) {
         if (isJson(input)) {
-            return input;
+            if (!escapeJson) {
+                return input;
+            } else {
+                return escapeJson(input);
+            }
         }
         return escapeJson(input);
     }
diff --git a/common/src/main/java/org/opensearch/ml/common/utils/ToolUtils.java b/common/src/main/java/org/opensearch/ml/common/utils/ToolUtils.java
index becf53e3c8..d80b8c6794 100644
--- a/common/src/main/java/org/opensearch/ml/common/utils/ToolUtils.java
+++ b/common/src/main/java/org/opensearch/ml/common/utils/ToolUtils.java
@@ -33,6 +33,7 @@
 public class ToolUtils {
 
     public static final String TOOL_OUTPUT_FILTERS_FIELD = "output_filter";
+    public static final String TOOL_ESCAPE_OUTPUT = "escape_output";
     public static final String TOOL_REQUIRED_PARAMS = "required_parameters";
     public static final String NO_ESCAPE_PARAMS = "no_escape_params";
 
diff --git a/common/src/test/java/org/opensearch/ml/common/utils/StringUtilsTest.java b/common/src/test/java/org/opensearch/ml/common/utils/StringUtilsTest.java
index a64630de40..f2bb9aa4fd 100644
--- a/common/src/test/java/org/opensearch/ml/common/utils/StringUtilsTest.java
+++ b/common/src/test/java/org/opensearch/ml/common/utils/StringUtilsTest.java
@@ -861,14 +861,21 @@ public void testValidateFields_InvalidCharacterSet() {
     @Test
     public void prepareJsonValue_returnsRawIfJson() {
         String json = "{\"key\": 123}";
-        String result = StringUtils.prepareJsonValue(json);
+        String result = StringUtils.prepareJsonValue(json, false);
         assertSame(json, result);  // branch where isJson(input)==true
     }
 
+    @Test
+    public void prepareJsonValue_returnEscapeJsonIfForce() {
+        String json = "{\"key\": 123}";
+        String result = StringUtils.prepareJsonValue(json, true);
+        assertEquals("{\\\"key\\\": 123}", result);
+    }
+
     @Test
     public void prepareJsonValue_escapesBadCharsOtherwise() {
         String input = "Tom & Jerry \"<script>";
-        String escaped = StringUtils.prepareJsonValue(input);
+        String escaped = StringUtils.prepareJsonValue(input, false);
         assertNotEquals(input, escaped);
         assertFalse(StringUtils.isJson(escaped));
         assertEquals("Tom & Jerry \\\"<script>", escaped);
diff --git a/ml-algorithms/src/main/java/org/opensearch/ml/engine/algorithms/agent/MLConversationalFlowAgentRunner.java b/ml-algorithms/src/main/java/org/opensearch/ml/engine/algorithms/agent/MLConversationalFlowAgentRunner.java
index 5a4ce8e796..1983acef0e 100644
--- a/ml-algorithms/src/main/java/org/opensearch/ml/engine/algorithms/agent/MLConversationalFlowAgentRunner.java
+++ b/ml-algorithms/src/main/java/org/opensearch/ml/engine/algorithms/agent/MLConversationalFlowAgentRunner.java
@@ -9,6 +9,7 @@
 import static org.opensearch.ml.common.conversation.ActionConstants.AI_RESPONSE_FIELD;
 import static org.opensearch.ml.common.conversation.ActionConstants.MEMORY_ID;
 import static org.opensearch.ml.common.conversation.ActionConstants.PARENT_INTERACTION_ID_FIELD;
+import static org.opensearch.ml.common.utils.ToolUtils.TOOL_ESCAPE_OUTPUT;
 import static org.opensearch.ml.common.utils.ToolUtils.TOOL_OUTPUT_FILTERS_FIELD;
 import static org.opensearch.ml.common.utils.ToolUtils.filterToolOutput;
 import static org.opensearch.ml.common.utils.ToolUtils.getToolName;
@@ -262,7 +263,11 @@ private void processOutput(
         String outputKey = toolName + ".output";
         Map<String, String> toolParameters = ToolUtils.buildToolParameters(params, previousToolSpec, tenantId);
         String filteredOutput = parseResponse(filterToolOutput(toolParameters, output));
-        params.put(outputKey, StringUtils.prepareJsonValue(filteredOutput));
+        params
+            .put(
+                outputKey,
+                StringUtils.prepareJsonValue(filteredOutput, Boolean.parseBoolean(toolParameters.getOrDefault(TOOL_ESCAPE_OUTPUT, "false")))
+            );
         boolean traceDisabled = params.containsKey(DISABLE_TRACE) && Boolean.parseBoolean(params.get(DISABLE_TRACE));
 
         if (previousToolSpec.isIncludeOutputInAgentResponse() || finalI == toolSpecs.size()) {
diff --git a/ml-algorithms/src/main/java/org/opensearch/ml/engine/algorithms/agent/MLFlowAgentRunner.java b/ml-algorithms/src/main/java/org/opensearch/ml/engine/algorithms/agent/MLFlowAgentRunner.java
index 4708b4a8e4..e0da275c31 100644
--- a/ml-algorithms/src/main/java/org/opensearch/ml/engine/algorithms/agent/MLFlowAgentRunner.java
+++ b/ml-algorithms/src/main/java/org/opensearch/ml/engine/algorithms/agent/MLFlowAgentRunner.java
@@ -5,6 +5,7 @@
 
 package org.opensearch.ml.engine.algorithms.agent;
 
+import static org.opensearch.ml.common.utils.ToolUtils.TOOL_ESCAPE_OUTPUT;
 import static org.opensearch.ml.common.utils.ToolUtils.TOOL_OUTPUT_FILTERS_FIELD;
 import static org.opensearch.ml.common.utils.ToolUtils.filterToolOutput;
 import static org.opensearch.ml.common.utils.ToolUtils.getToolName;
@@ -114,7 +115,15 @@ public void run(MLAgent mlAgent, Map<String, String> params, ActionListener<Obje
                     String outputKey = toolName + ".output";
                     Map<String, String> toolParameters = ToolUtils.buildToolParameters(params, previousToolSpec, mlAgent.getTenantId());
                     String filteredOutput = parseResponse(filterToolOutput(toolParameters, output));
-                    params.put(outputKey, StringUtils.prepareJsonValue(filteredOutput));
+                    params
+                        .put(
+                            outputKey,
+                            StringUtils
+                                .prepareJsonValue(
+                                    filteredOutput,
+                                    Boolean.parseBoolean(toolParameters.getOrDefault(TOOL_ESCAPE_OUTPUT, "false"))
+                                )
+                        );
                     if (previousToolSpec.isIncludeOutputInAgentResponse() || finalI == toolSpecs.size()) {
                         if (toolParameters.containsKey(TOOL_OUTPUT_FILTERS_FIELD)) {
                             flowAgentOutput.add(ModelTensor.builder().name(outputKey).result(filteredOutput).build());