From 8f81e81c2cc74c86724c9ebd528e5dd3bbdec4b6 Mon Sep 17 00:00:00 2001 From: manan164 <1897158+manan164@users.noreply.github.com> Date: Fri, 29 Nov 2024 14:03:35 +0530 Subject: [PATCH] changes --- .../conductor/core/execution/mapper/SubWorkflowTaskMapper.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/core/src/main/java/com/netflix/conductor/core/execution/mapper/SubWorkflowTaskMapper.java b/core/src/main/java/com/netflix/conductor/core/execution/mapper/SubWorkflowTaskMapper.java index f59d67364..7340d36f1 100644 --- a/core/src/main/java/com/netflix/conductor/core/execution/mapper/SubWorkflowTaskMapper.java +++ b/core/src/main/java/com/netflix/conductor/core/execution/mapper/SubWorkflowTaskMapper.java @@ -78,6 +78,7 @@ public List getMappedTasks(TaskMapperContext taskMapperContext) { TaskModel subWorkflowTask = taskMapperContext.createTaskModel(); subWorkflowTask.setTaskType(TASK_TYPE_SUB_WORKFLOW); subWorkflowTask.addInput("subWorkflowName", subWorkflowName); + subWorkflowTask.addInput("priority", resolvedParams.get("priority")); subWorkflowTask.addInput("subWorkflowVersion", subWorkflowVersion); subWorkflowTask.addInput("subWorkflowTaskToDomain", subWorkflowTaskToDomain); subWorkflowTask.addInput("subWorkflowDefinition", subWorkflowDefinition); @@ -111,6 +112,7 @@ private Map getSubWorkflowInputParameters( WorkflowModel workflowModel, SubWorkflowParams subWorkflowParams) { Map params = new HashMap<>(); params.put("name", subWorkflowParams.getName()); + params.put("priority", subWorkflowParams.getPriority()); Integer version = subWorkflowParams.getVersion(); if (version != null) {