Skip to content

Commit 97f1199

Browse files
committed
add logs
Signed-off-by: xinyual <xinyual@amazon.com>
1 parent 1a436fe commit 97f1199

File tree

2 files changed

+21
-0
lines changed

2 files changed

+21
-0
lines changed

ml-algorithms/src/main/java/org/opensearch/ml/engine/tools/AgentTool.java

+19
Original file line numberDiff line numberDiff line change
@@ -24,6 +24,8 @@
2424
import lombok.Setter;
2525
import lombok.extern.log4j.Log4j2;
2626

27+
import static org.opensearch.ml.common.utils.StringUtils.gson;
28+
2729
/**
2830
* This tool supports running any Agent.
2931
*/
@@ -51,6 +53,11 @@ public AgentTool(Client client, String agentId) {
5153

5254
@Override
5355
public <T> void run(Map<String, String> parameters, ActionListener<T> listener) {
56+
log.info("Agent tool before");
57+
log.info(parameters);
58+
parameters = extractFromChatParameters(parameters);
59+
log.info("Agent tool after");
60+
log.info(parameters);
5461
AgentMLInput agentMLInput = AgentMLInput
5562
.AgentMLInputBuilder()
5663
.agentId(agentId)
@@ -135,4 +142,16 @@ public String getDefaultVersion() {
135142
return null;
136143
}
137144
}
145+
146+
private Map<String, String> extractFromChatParameters(Map<String, String> parameters) {
147+
if (parameters.containsKey("input")) {
148+
try {
149+
Map<String, String> chatParameters = gson.fromJson(parameters.get("input"), Map.class);
150+
parameters.putAll(chatParameters);
151+
} finally {
152+
return parameters;
153+
}
154+
}
155+
return parameters;
156+
}
138157
}

ml-algorithms/src/main/java/org/opensearch/ml/engine/tools/MLModelTool.java

+2
Original file line numberDiff line numberDiff line change
@@ -65,6 +65,8 @@ public MLModelTool(Client client, String modelId) {
6565

6666
@Override
6767
public <T> void run(Map<String, String> parameters, ActionListener<T> listener) {
68+
log.info("ML input");
69+
log.info(parameters);
6870
RemoteInferenceInputDataSet inputDataSet = RemoteInferenceInputDataSet.builder().parameters(parameters).build();
6971
ActionRequest request = new MLPredictionTaskRequest(
7072
modelId,

0 commit comments

Comments
 (0)