add get workflow history async grpc API (#702)

cadence-workflow · Jul 27, 2022 · 9fd6ad9 · 9fd6ad9
1 parent d3a8515
commit 9fd6ad9
Showing 1 changed file with 22 additions and 18 deletions.
diff --git a/src/main/java/com/uber/cadence/internal/compatibility/Thrift2ProtoAdapter.java b/src/main/java/com/uber/cadence/internal/compatibility/Thrift2ProtoAdapter.java
@@ -1074,24 +1074,28 @@ public void GetWorkflowExecutionHistoryWithTimeout(
       AsyncMethodCallback resultHandler,
       Long timeoutInMillis)
       throws TException {
-    // TODO test
-    ListenableFuture<com.uber.cadence.api.v1.GetWorkflowExecutionHistoryResponse> resultFuture =
-        grpcServiceStubs
-            .workflowFutureStub()
-            .withDeadline(Deadline.after(timeoutInMillis, TimeUnit.MILLISECONDS))
-            .getWorkflowExecutionHistory(
-                RequestMapper.getWorkflowExecutionHistoryRequest(getRequest));
-    resultFuture.addListener(
-        () -> {
-          try {
-            com.uber.cadence.api.v1.GetWorkflowExecutionHistoryResponse response =
-                resultFuture.get();
-            resultHandler.onComplete(ResponseMapper.getWorkflowExecutionHistoryResponse(response));
-          } catch (Exception e) {
-            resultHandler.onError(e);
-          }
-        },
-        ForkJoinPool.commonPool());
+    try {
+      ListenableFuture<com.uber.cadence.api.v1.GetWorkflowExecutionHistoryResponse> resultFuture =
+          grpcServiceStubs
+              .workflowFutureStub()
+              .withDeadline(Deadline.after(timeoutInMillis, TimeUnit.MILLISECONDS))
+              .getWorkflowExecutionHistory(
+                  RequestMapper.getWorkflowExecutionHistoryRequest(getRequest));
+      resultFuture.addListener(
+          () -> {
+            try {
+              com.uber.cadence.api.v1.GetWorkflowExecutionHistoryResponse response =
+                  resultFuture.get();
+              resultHandler
+                  .onComplete(ResponseMapper.getWorkflowExecutionHistoryResponse(response));
+            } catch (Exception e) {
+              resultHandler.onError(e);
+            }
+          },
+          ForkJoinPool.commonPool());
+    } catch (StatusRuntimeException e) {
+      throw ErrorMapper.Error(e);
+    }
   }
 
   @Override