We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent efbed09 commit 9e42697Copy full SHA for 9e42697
core/src/main/java/com/netflix/conductor/core/execution/WorkflowExecutorOps.java
@@ -870,12 +870,10 @@ public TaskModel updateTask(TaskResult taskResult) {
870
LOGGER.error(errorMsg, e);
871
}
872
List<TaskExecLog> taskLogs = taskResult.getLogs();
873
- Optional.ofNullable(taskLogs)
874
- .ifPresent(
875
- logs -> {
876
- logs.forEach(taskExecLog -> taskExecLog.setTaskId(task.getTaskId()));
877
- executionDAOFacade.addTaskExecLog(taskLogs);
878
- });
+ if (null != taskLogs) {
+ taskLogs.forEach(taskExecLog -> taskExecLog.setTaskId(task.getTaskId()));
+ executionDAOFacade.addTaskExecLog(taskLogs);
+ }
879
if (task.getStatus().isTerminal()) {
880
long duration = getTaskDuration(0, task);
881
long lastDuration = task.getEndTime() - task.getStartTime();
0 commit comments