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 sortProcessNodes(Workflow workflow, String workflowId, ProcessNode processNode = new ProcessNode( node.id(), step, - params, node.previousNodeInputs(), + params, data, predecessorNodes, threadPool,