diff --git a/core/src/main/java/com/netflix/conductor/core/execution/tasks/SubWorkflow.java b/core/src/main/java/com/netflix/conductor/core/execution/tasks/SubWorkflow.java index bedc874918..f22a7bce6f 100644 --- a/core/src/main/java/com/netflix/conductor/core/execution/tasks/SubWorkflow.java +++ b/core/src/main/java/com/netflix/conductor/core/execution/tasks/SubWorkflow.java @@ -61,6 +61,7 @@ public void start(Workflow workflow, Task task, WorkflowExecutor provider) throw String subWorkflowId = provider.startWorkflow(name, version, wfInput, correlationId, workflow.getWorkflowId(), task.getTaskId(), null); task.getOutputData().put("subWorkflowId", subWorkflowId); + task.getInputData().put("subWorkflowId", subWorkflowId); task.setStatus(Status.IN_PROGRESS); } catch (Exception e) {