[Backport 2.x] Fix bug passing params to workflows (opensearch-projec…

…t#560) Fix bug passing params to workflows (opensearch-project#559) (cherry picked from commit 4bf6e32) Signed-off-by: Daniel Widdis <[email protected]> Signed-off-by: github-actions[bot] <github-actions[bot]@users.noreply.github.com> Co-authored-by: github-actions[bot] <github-actions[bot]@users.noreply.github.com>
joshpalis · Mar 11, 2024 · 763f1c1 · 763f1c1
1 parent 2fcabf8
commit 763f1c1
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/src/main/java/org/opensearch/flowframework/transport/CreateWorkflowTransportAction.java b/src/main/java/org/opensearch/flowframework/transport/CreateWorkflowTransportAction.java
@@ -158,7 +158,8 @@ protected void doExecute(Task task, WorkflowRequest request, ActionListener<Work
                                                 if (request.isProvision()) {
                                                     WorkflowRequest workflowRequest = new WorkflowRequest(
                                                         globalContextResponse.getId(),
-                                                        null
+                                                        null,
+                                                        request.getParams()
                                                     );
                                                     logger.info(
                                                         "Provisioning parameter is set, continuing to provision workflow {}",

diff --git a/src/main/java/org/opensearch/flowframework/workflow/WorkflowProcessSorter.java b/src/main/java/org/opensearch/flowframework/workflow/WorkflowProcessSorter.java
@@ -123,8 +123,8 @@ public List<ProcessNode> sortProcessNodes(Workflow workflow, String workflowId,
             ProcessNode processNode = new ProcessNode(
                 node.id(),
                 step,
-                params,
                 node.previousNodeInputs(),
+                params,
                 data,
                 predecessorNodes,
                 threadPool,