Skip to content

Commit 5ff4197

Browse files
authored
grpc reset task list error handling (#707)
1 parent 0d6259c commit 5ff4197

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
@@ -623,11 +623,15 @@ public ResetStickyTaskListResponse ResetStickyTaskList(ResetStickyTaskListReques
623623
throws BadRequestError, EntityNotExistsError, LimitExceededError, ServiceBusyError,
624624
DomainNotActiveError, ClientVersionNotSupportedError,
625625
WorkflowExecutionAlreadyCompletedError, TException {
626-
com.uber.cadence.api.v1.ResetStickyTaskListResponse response =
627-
grpcServiceStubs
628-
.workerBlockingStub()
629-
.resetStickyTaskList(RequestMapper.resetStickyTaskListRequest(resetRequest));
630-
return new ResetStickyTaskListResponse();
626+
try {
627+
com.uber.cadence.api.v1.ResetStickyTaskListResponse response =
628+
grpcServiceStubs
629+
.workerBlockingStub()
630+
.resetStickyTaskList(RequestMapper.resetStickyTaskListRequest(resetRequest));
631+
return new ResetStickyTaskListResponse();
632+
} catch (StatusRuntimeException e) {
633+
throw ErrorMapper.Error(e);
634+
}
631635
}
632636

633637
@Override

0 commit comments

Comments
 (0)