Skip to content

Commit 0e4e4d3

Browse files
authored
handle gRPC status error for query API (#709)
1 parent 015ae0c commit 0e4e4d3

File tree

1 file changed

+8
-3
lines changed

1 file changed

+8
-3
lines changed

src/main/java/com/uber/cadence/internal/compatibility/Thrift2ProtoAdapter.java

Lines changed: 8 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -613,9 +613,14 @@ public GetSearchAttributesResponse GetSearchAttributes()
613613
public void RespondQueryTaskCompleted(RespondQueryTaskCompletedRequest completeRequest)
614614
throws BadRequestError, EntityNotExistsError, LimitExceededError, ServiceBusyError,
615615
DomainNotActiveError, ClientVersionNotSupportedError, TException {
616-
grpcServiceStubs
617-
.workerBlockingStub()
618-
.respondQueryTaskCompleted(RequestMapper.respondQueryTaskCompletedRequest(completeRequest));
616+
try {
617+
grpcServiceStubs
618+
.workerBlockingStub()
619+
.respondQueryTaskCompleted(
620+
RequestMapper.respondQueryTaskCompletedRequest(completeRequest));
621+
} catch (StatusRuntimeException e) {
622+
throw ErrorMapper.Error(e);
623+
}
619624
}
620625

621626
@Override

0 commit comments

Comments
 (0)