diff --git a/hypertrace-graphql-entity-schema/src/main/java/org/hypertrace/graphql/entity/dao/GatewayServiceEntityDao.java b/hypertrace-graphql-entity-schema/src/main/java/org/hypertrace/graphql/entity/dao/GatewayServiceEntityDao.java index 0d5b3f93..50ef90c3 100644 --- a/hypertrace-graphql-entity-schema/src/main/java/org/hypertrace/graphql/entity/dao/GatewayServiceEntityDao.java +++ b/hypertrace-graphql-entity-schema/src/main/java/org/hypertrace/graphql/entity/dao/GatewayServiceEntityDao.java @@ -84,7 +84,8 @@ public Single getEntities(EntityRequest request) { return this.requestBuilder .buildRequest(request) .subscribeOn(this.boundedIoScheduler) - .flatMap(serverRequest -> this.fetchAndMapEntities(context, request, serverRequest)); + .flatMap(serverRequest -> this.fetchAndMapEntities(context, request, serverRequest)) + .doOnError(error -> log.error("Error while handling entities request {}", request, error)); } private Single fetchAndMapEntities( diff --git a/hypertrace-graphql-explorer-schema/src/main/java/org/hypertrace/graphql/explorer/dao/GatewayServiceExplorerDao.java b/hypertrace-graphql-explorer-schema/src/main/java/org/hypertrace/graphql/explorer/dao/GatewayServiceExplorerDao.java index fd721b14..47a49ff5 100644 --- a/hypertrace-graphql-explorer-schema/src/main/java/org/hypertrace/graphql/explorer/dao/GatewayServiceExplorerDao.java +++ b/hypertrace-graphql-explorer-schema/src/main/java/org/hypertrace/graphql/explorer/dao/GatewayServiceExplorerDao.java @@ -7,6 +7,7 @@ import io.reactivex.rxjava3.core.Single; import javax.inject.Inject; import javax.inject.Singleton; +import lombok.extern.slf4j.Slf4j; import org.hypertrace.core.graphql.context.GraphQlRequestContext; import org.hypertrace.core.graphql.request.transformation.RequestTransformer; import org.hypertrace.core.graphql.rx.BoundedIoScheduler; @@ -19,6 +20,7 @@ import org.hypertrace.graphql.explorer.request.ExploreRequest; import org.hypertrace.graphql.explorer.schema.ExploreResultSet; +@Slf4j @Singleton class GatewayServiceExplorerDao implements ExplorerDao { private final GatewayServiceFutureStub gatewayServiceStub; @@ -60,7 +62,8 @@ public Single explore(ExploreRequest request) { .flatMap(this.requestBuilder::buildRequest) .subscribeOn(this.boundedIoScheduler) .flatMap(serverRequest -> this.makeRequest(request.context(), serverRequest)) - .flatMap(serverResponse -> this.responseConverter.convert(request, serverResponse)); + .flatMap(serverResponse -> this.responseConverter.convert(request, serverResponse)) + .doOnError(error -> log.error("Error while handling explore request {}", request, error)); } private Single makeRequest(