in data-catalog-api/server/service/src/main/java/org/apache/airavata/datacatalog/api/service/DataCatalogAPIService.java [69:87]
public void createDataProduct(DataProductCreateRequest request,
StreamObserver<DataProductCreateResponse> responseObserver) {
logger.info("Creating data product {}", request.getDataProduct());
// Set the owner as the requesting user
DataProduct dataProduct = request.getDataProduct().toBuilder().setOwner(request.getUserInfo()).build();
DataProduct result;
try {
result = dataCatalogService.createDataProduct(dataProduct);
responseObserver.onNext(DataProductCreateResponse.newBuilder().setDataProduct(result).build());
responseObserver.onCompleted();
} catch (SharingException e) {
logger.error("Sharing error when trying to create data product", e);
responseObserver.onError(Status.INTERNAL.withDescription(e.getMessage()).asException());
}
}