Skip to content

Commit 9ad5db2

Browse files
committed
add test and fix
1 parent 6e017f9 commit 9ad5db2

File tree

2 files changed

+2074
-7
lines changed

2 files changed

+2074
-7
lines changed

src/main/java/com/uber/cadence/serviceclient/WorkflowServiceTChannel.java

Lines changed: 13 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -776,6 +776,9 @@ private GetWorkflowExecutionHistoryResponse getWorkflowExecutionHistory(
776776
if (result.isSetServiceBusyError()) {
777777
throw result.getServiceBusyError();
778778
}
779+
if (result.isSetClientVersionNotSupportedError()) {
780+
throw result.getClientVersionNotSupportedError();
781+
}
779782
throw new TException("GetWorkflowExecutionHistory failed with unknown error:" + result);
780783
} finally {
781784
if (response != null) {
@@ -2090,6 +2093,9 @@ private QueryWorkflowResponse queryWorkflow(QueryWorkflowRequest queryRequest) t
20902093
if (result.isSetBadRequestError()) {
20912094
throw result.getBadRequestError();
20922095
}
2096+
if (result.isSetServiceBusyError()) {
2097+
throw result.getServiceBusyError();
2098+
}
20932099
if (result.isSetEntityNotExistError()) {
20942100
throw result.getEntityNotExistError();
20952101
}
@@ -2265,6 +2271,9 @@ private ClusterInfo getClusterInfo() throws TException {
22652271
if (result.isSetServiceBusyError()) {
22662272
throw result.getServiceBusyError();
22672273
}
2274+
if (result.isSetInternalServiceError()) {
2275+
throw result.getInternalServiceError();
2276+
}
22682277
throw new TException("GetClusterInfo failed with unknown error:" + result);
22692278
} finally {
22702279
if (response != null) {
@@ -2295,6 +2304,9 @@ public void RefreshWorkflowTasks(RefreshWorkflowTasksRequest refreshWorkflowTask
22952304
response = doRemoteCall(request);
22962305
WorkflowService.RefreshWorkflowTasks_result result =
22972306
response.getBody(WorkflowService.RefreshWorkflowTasks_result.class);
2307+
if (response.getResponseCode() == ResponseCode.OK) {
2308+
return;
2309+
}
22982310
if (result.isSetBadRequestError()) {
22992311
throw result.getBadRequestError();
23002312
}
@@ -2307,6 +2319,7 @@ public void RefreshWorkflowTasks(RefreshWorkflowTasksRequest refreshWorkflowTask
23072319
if (result.isSetEntityNotExistError()) {
23082320
throw result.getEntityNotExistError();
23092321
}
2322+
throw new TException("RefreshWorkflowTasks failed with unknown error:" + result);
23102323
} finally {
23112324
if (response != null) {
23122325
response.release();

0 commit comments

Comments
 (0)