check grpc WorkflowExecutionAlreadyCompletedError status (#708)

Author: mkolodezny

src/main/java/com/uber/cadence/internal/compatibility/thrift/ErrorMapper.java

@@ -41,43 +41,47 @@ public static TException Error(StatusRuntimeException ex) {
         return new AccessDeniedError(ex.getMessage());
       case INTERNAL:
         return new InternalServiceError(ex.getMessage());
-      case NOT_FOUND: {
-        switch (details) {
-          case "EntityNotExistsError":
+      case NOT_FOUND:
+        {
+          if ("EntityNotExistsError".equals(details)
+              && ex.getMessage().contains("already completed.")) {
+            return new WorkflowExecutionAlreadyCompletedError(ex.getMessage());
+          } else {
             // TODO add cluster info
             return new EntityNotExistsError(ex.getMessage());
-          case "WorkflowExecutionAlreadyCompletedError":
-            return new WorkflowExecutionAlreadyCompletedError(ex.getMessage());
+          }
         }
-      }
-      case ALREADY_EXISTS: {
-        switch (details) {
-          case "CancellationAlreadyRequestedError":
-            return new CancellationAlreadyRequestedError(ex.getMessage());
-          case "DomainAlreadyExistsError":
-            return new DomainAlreadyExistsError(ex.getMessage());
-          case "WorkflowExecutionAlreadyStartedError": {
-            // TODO add started wf info
-            WorkflowExecutionAlreadyStartedError e = new WorkflowExecutionAlreadyStartedError();
-            e.setMessage(ex.getMessage());
-            return e;
+      case ALREADY_EXISTS:
+        {
+          switch (details) {
+            case "CancellationAlreadyRequestedError":
+              return new CancellationAlreadyRequestedError(ex.getMessage());
+            case "DomainAlreadyExistsError":
+              return new DomainAlreadyExistsError(ex.getMessage());
+            case "WorkflowExecutionAlreadyStartedError":
+              {
+                // TODO add started wf info
+                WorkflowExecutionAlreadyStartedError e = new WorkflowExecutionAlreadyStartedError();
+                e.setMessage(ex.getMessage());
+                return e;
+              }
           }
         }
-      }
       case DATA_LOSS:
         return new InternalDataInconsistencyError(ex.getMessage());
       case FAILED_PRECONDITION:
         switch (details) {
-          // TODO add infos
+            // TODO add infos
           case "ClientVersionNotSupportedError":
             return new ClientVersionNotSupportedError();
           case "FeatureNotEnabledError":
             return new FeatureNotEnabledError();
-          case "DomainNotActiveError": {
-            DomainNotActiveError e = new DomainNotActiveError();
-            e.setMessage(ex.getMessage());
-            return e;
-          }
+          case "DomainNotActiveError":
+            {
+              DomainNotActiveError e = new DomainNotActiveError();
+              e.setMessage(ex.getMessage());
+              return e;
+            }
         }
       case RESOURCE_EXHAUSTED:
         switch (details) {