handle NPE

conductor-oss · Oct 14, 2024 · 16a7c07 · 16a7c07
1 parent c800fed
commit 16a7c07
Showing 1 changed file with 3 additions and 1 deletion.
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
@@ -83,7 +83,9 @@ public List<TaskModel> getMappedTasks(TaskMapperContext taskMapperContext) {
         subWorkflowTask.addInput("workflowInput", taskMapperContext.getTaskInput());
         subWorkflowTask.setStatus(TaskModel.Status.SCHEDULED);
         subWorkflowTask.setCallbackAfterSeconds(workflowTask.getStartDelay());
-        subWorkflowTask.setWorkflowPriority(subWorkflowParams.getPriority());
+        if (subWorkflowParams.getPriority() != null) {
+            subWorkflowTask.setWorkflowPriority(subWorkflowParams.getPriority());
+        }
         LOGGER.debug("SubWorkflowTask {} created to be Scheduled", subWorkflowTask);
         return List.of(subWorkflowTask);
     }