Fix bug passing params to workflows (opensearch-project#559)

Signed-off-by: Daniel Widdis <[email protected]>
joshpalis · Mar 11, 2024 · 4bf6e32 · 4bf6e32
1 parent 2707210
commit 4bf6e32
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,