Missed added steps passing from executor to planner

[mingshl]

there are times I found executor executed 6 steps, but planner only got 5 steps result
when constructed the MLPredictionTask too earlier before executor agent run,
https://github.com/opensearch-project/ml-commons/blob/main/ml-algorithms/src/main/[…]engine/algorithms/agent/MLPlanExecuteAndReflectAgentRunner.java
on L389
the added steps at line 520
https://github.com/opensearch-project/ml-commons/blob/main/ml-algorithms/src/main/[…]engine/algorithms/agent/MLPlanExecuteAndReflectAgentRunner.java
didn't changed the request for MLPredictionTask. the added step is missed.

[pyek-bot]

It's a recursive loop of planning and execution.

The request gets created here using the previous set of params:

ml-commons/ml-algorithms/src/main/java/org/opensearch/ml/engine/algorithms/agent/MLPlanExecuteAndReflectAgentRunner.java

Line 389 in 0ff1d76

MLPredictionTaskRequest request = new MLPredictionTaskRequest(

In the first call, it will simply be the objective with no completed steps.

This is the first call that triggers the recursive loop:

ml-commons/ml-algorithms/src/main/java/org/opensearch/ml/engine/algorithms/agent/MLPlanExecuteAndReflectAgentRunner.java

Line 544 in 0ff1d76

client.execute(MLPredictionTaskAction.INSTANCE, request, planListener);

which uses a planListener. The planListener is defined here:

ml-commons/ml-algorithms/src/main/java/org/opensearch/ml/engine/algorithms/agent/MLPlanExecuteAndReflectAgentRunner.java

Line 402 in 0ff1d76

planListener.whenComplete(llmOutput -> {

This listener recursively calls the parent method executePlanningLoop with the newly updated params:

ml-commons/ml-algorithms/src/main/java/org/opensearch/ml/engine/algorithms/agent/MLPlanExecuteAndReflectAgentRunner.java

Line 524 in 0ff1d76

executePlanningLoop(

This loop continues until a result is found where instead of executePlanningLoop it calls saveAndReturnFinalResult:

ml-commons/ml-algorithms/src/main/java/org/opensearch/ml/engine/algorithms/agent/MLPlanExecuteAndReflectAgentRunner.java

Line 408 in 0ff1d76

saveAndReturnFinalResult(