Skip to content

Commit 6d9c640

Browse files
authored
add cluster info grpc API (#704)
1 parent 6e037d0 commit 6d9c640

File tree

1 file changed

+9
-5
lines changed

1 file changed

+9
-5
lines changed

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

Lines changed: 9 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -671,11 +671,15 @@ public DescribeTaskListResponse DescribeTaskList(DescribeTaskListRequest request
671671

672672
@Override
673673
public ClusterInfo GetClusterInfo() throws InternalServiceError, ServiceBusyError, TException {
674-
com.uber.cadence.api.v1.GetClusterInfoResponse response =
675-
grpcServiceStubs
676-
.workflowBlockingStub()
677-
.getClusterInfo(com.uber.cadence.api.v1.GetClusterInfoRequest.newBuilder().build());
678-
return ResponseMapper.getClusterInfoResponse(response);
674+
try {
675+
com.uber.cadence.api.v1.GetClusterInfoResponse response =
676+
grpcServiceStubs
677+
.workflowBlockingStub()
678+
.getClusterInfo(com.uber.cadence.api.v1.GetClusterInfoRequest.newBuilder().build());
679+
return ResponseMapper.getClusterInfoResponse(response);
680+
} catch (StatusRuntimeException e) {
681+
throw ErrorMapper.Error(e);
682+
}
679683
}
680684

681685
@Override

0 commit comments

Comments
 (0)