Skip to content
Merged
Show file tree
Hide file tree
Changes from 2 commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
1 change: 1 addition & 0 deletions build.gradle
Original file line number Diff line number Diff line change
Expand Up @@ -84,6 +84,7 @@ dependencies {
testCompile group: 'io.grpc', name: 'grpc-testing', version: '1.54.2'
testImplementation 'io.opentracing:opentracing-mock:0.33.0'
testImplementation group: 'org.mockito', name: 'mockito-core', version: '4.5.1'
testImplementation "org.mockito:mockito-inline:4.5.1" // for mocking final classes
}

license {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -776,6 +776,9 @@ private GetWorkflowExecutionHistoryResponse getWorkflowExecutionHistory(
if (result.isSetServiceBusyError()) {
throw result.getServiceBusyError();
}
if (result.isSetClientVersionNotSupportedError()) {
throw result.getClientVersionNotSupportedError();
}
throw new TException("GetWorkflowExecutionHistory failed with unknown error:" + result);
} finally {
if (response != null) {
Expand Down Expand Up @@ -2090,6 +2093,9 @@ private QueryWorkflowResponse queryWorkflow(QueryWorkflowRequest queryRequest) t
if (result.isSetBadRequestError()) {
throw result.getBadRequestError();
}
if (result.isSetServiceBusyError()) {
throw result.getServiceBusyError();
}
if (result.isSetEntityNotExistError()) {
throw result.getEntityNotExistError();
}
Expand Down Expand Up @@ -2265,6 +2271,9 @@ private ClusterInfo getClusterInfo() throws TException {
if (result.isSetServiceBusyError()) {
throw result.getServiceBusyError();
}
if (result.isSetInternalServiceError()) {
throw result.getInternalServiceError();
}
throw new TException("GetClusterInfo failed with unknown error:" + result);
} finally {
if (response != null) {
Expand Down Expand Up @@ -2295,6 +2304,9 @@ public void RefreshWorkflowTasks(RefreshWorkflowTasksRequest refreshWorkflowTask
response = doRemoteCall(request);
WorkflowService.RefreshWorkflowTasks_result result =
response.getBody(WorkflowService.RefreshWorkflowTasks_result.class);
if (response.getResponseCode() == ResponseCode.OK) {
return;
}
if (result.isSetBadRequestError()) {
throw result.getBadRequestError();
}
Expand All @@ -2307,6 +2319,7 @@ public void RefreshWorkflowTasks(RefreshWorkflowTasksRequest refreshWorkflowTask
if (result.isSetEntityNotExistError()) {
throw result.getEntityNotExistError();
}
throw new TException("RefreshWorkflowTasks failed with unknown error:" + result);
} finally {
if (response != null) {
response.release();
Expand Down
Loading
Loading