in data-catalog-api/server/service/src/main/java/org/apache/airavata/datacatalog/api/service/DataCatalogAPIService.java [193:209]
public void searchDataProducts(DataProductSearchRequest request,
StreamObserver<DataProductSearchResponse> responseObserver) {
try {
MetadataSchemaQueryResult searchResult = dataCatalogService.searchDataProducts(request.getUserInfo(),
request.getSql());
List<DataProduct> dataProducts = searchResult.dataProducts();
responseObserver.onNext(DataProductSearchResponse.newBuilder().addAllDataProducts(dataProducts).build());
responseObserver.onCompleted();
} catch (MetadataSchemaSqlParseException e) {
responseObserver
.onError(Status.INVALID_ARGUMENT.withDescription("Failed to parse SQL query.").asException());
} catch (MetadataSchemaSqlValidateException e) {
responseObserver
.onError(Status.INVALID_ARGUMENT.withDescription("Failed to validate SQL query.").asException());
}
}