From 4bf6e329097610021b39b3570a5274de5a264946 Mon Sep 17 00:00:00 2001
From: Daniel Widdis <widdis@gmail.com>
Date: Mon, 11 Mar 2024 10:36:45 -0700
Subject: [PATCH] Fix bug passing params to workflows (#559)

Signed-off-by: Daniel Widdis <widdis@gmail.com>
---
 .../flowframework/transport/CreateWorkflowTransportAction.java | 3 ++-
 .../flowframework/workflow/WorkflowProcessSorter.java          | 2 +-
 2 files changed, 3 insertions(+), 2 deletions(-)

diff --git a/src/main/java/org/opensearch/flowframework/transport/CreateWorkflowTransportAction.java b/src/main/java/org/opensearch/flowframework/transport/CreateWorkflowTransportAction.java
index 677278a93..9dabd0c4a 100644
--- 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
index 26e60cd91..884968abc 100644
--- 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,