in src/main/java/com/epam/digital/data/platform/bphistory/service/api/service/impl/TaskService.java [67:76]
private Map<String, String> getProcessInstanceBusinessKeys(List<BpmHistoryTask> bpmHistoryTasks) {
var processInstanceIds = bpmHistoryTasks.stream()
.map(BpmHistoryTask::getRootProcessInstanceId)
.collect(Collectors.toSet());
return processRepository.findAllByProcessInstanceIdIn(processInstanceIds).stream()
.filter(bpmHistoryProcess -> Objects.nonNull(bpmHistoryProcess.getBusinessKey()))
.collect(Collectors.toMap(BpmHistoryProcess::getProcessInstanceId,
BpmHistoryProcess::getBusinessKey));
}