Skip to content

Commit 6e037d0

Browse files
authored
add tasklist grpc API (#703)
1 parent 9fd6ad9 commit 6e037d0

File tree

1 file changed

+18
-10
lines changed

1 file changed

+18
-10
lines changed

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

Lines changed: 18 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -658,11 +658,15 @@ public DescribeWorkflowExecutionResponse DescribeWorkflowExecution(
658658
public DescribeTaskListResponse DescribeTaskList(DescribeTaskListRequest request)
659659
throws BadRequestError, EntityNotExistsError, LimitExceededError, ServiceBusyError,
660660
ClientVersionNotSupportedError, TException {
661-
com.uber.cadence.api.v1.DescribeTaskListResponse response =
662-
grpcServiceStubs
663-
.workflowBlockingStub()
664-
.describeTaskList(RequestMapper.describeTaskListRequest(request));
665-
return ResponseMapper.describeTaskListResponse(response);
661+
try {
662+
com.uber.cadence.api.v1.DescribeTaskListResponse response =
663+
grpcServiceStubs
664+
.workflowBlockingStub()
665+
.describeTaskList(RequestMapper.describeTaskListRequest(request));
666+
return ResponseMapper.describeTaskListResponse(response);
667+
} catch (StatusRuntimeException e) {
668+
throw ErrorMapper.Error(e);
669+
}
666670
}
667671

668672
@Override
@@ -684,11 +688,15 @@ public ListTaskListPartitionsResponse ListTaskListPartitions(
684688
ListTaskListPartitionsRequest request)
685689
throws BadRequestError, EntityNotExistsError, LimitExceededError, ServiceBusyError,
686690
TException {
687-
com.uber.cadence.api.v1.ListTaskListPartitionsResponse response =
688-
grpcServiceStubs
689-
.workflowBlockingStub()
690-
.listTaskListPartitions(RequestMapper.listTaskListPartitionsRequest(request));
691-
return ResponseMapper.listTaskListPartitionsResponse(response);
691+
try {
692+
com.uber.cadence.api.v1.ListTaskListPartitionsResponse response =
693+
grpcServiceStubs
694+
.workflowBlockingStub()
695+
.listTaskListPartitions(RequestMapper.listTaskListPartitionsRequest(request));
696+
return ResponseMapper.listTaskListPartitionsResponse(response);
697+
} catch (StatusRuntimeException e) {
698+
throw ErrorMapper.Error(e);
699+
}
692700
}
693701

694702
@Override

0 commit comments

Comments
 (0)