File tree Expand file tree Collapse file tree 2 files changed +7
-7
lines changed
src/main/java/com/uber/cadence/internal/compatibility/proto/mappers Expand file tree Collapse file tree 2 files changed +7
-7
lines changed Original file line number Diff line number Diff line change @@ -61,10 +61,7 @@ public static CadenceError Error(StatusRuntimeException e) {
6161 if (detail .is (com .uber .cadence .api .v1 .WorkflowExecutionAlreadyCompletedError .class )) {
6262 return new WorkflowExecutionAlreadyCompletedError (e );
6363 } else if (detail .is (com .uber .cadence .api .v1 .EntityNotExistsError .class )
64- && status
65- .getMessage ()
66- .contains (
67- "Workflow execution already completed." )) {
64+ && status .getMessage ().contains ("Workflow execution already completed." )) {
6865 // old server returns EntityNotExistsError with message Workflow is alredy completed
6966 return new WorkflowExecutionAlreadyCompletedError (e );
7067 } else {
Original file line number Diff line number Diff line change @@ -925,7 +925,8 @@ public static RespondActivityTaskCompletedByIDRequest respondActivityTaskComplet
925925 completeRequest .getWorkflowID (), completeRequest .getRunID ()))
926926 .setActivityId (completeRequest .getActivityID ())
927927 .setResult (payload (completeRequest .getResult ()))
928- .setIdentity (completeRequest .getIdentity () != null ? completeRequest .getIdentity () : "" );
928+ .setIdentity (
929+ completeRequest .getIdentity () != null ? completeRequest .getIdentity () : "" );
929930 return request .build ();
930931 }
931932
@@ -942,7 +943,8 @@ public static RecordActivityTaskHeartbeatByIDRequest recordActivityTaskHeartbeat
942943 heartbeatRequest .getWorkflowID (), heartbeatRequest .getRunID ()))
943944 .setActivityId (heartbeatRequest .getActivityID ())
944945 .setDetails (payload (heartbeatRequest .getDetails ()))
945- .setIdentity (heartbeatRequest .getIdentity () != null ? heartbeatRequest .getIdentity () : "" );
946+ .setIdentity (
947+ heartbeatRequest .getIdentity () != null ? heartbeatRequest .getIdentity () : "" );
946948 return request .build ();
947949 }
948950
@@ -959,7 +961,8 @@ public static RespondActivityTaskCanceledByIDRequest respondActivityTaskCanceled
959961 canceledRequest .getWorkflowID (), canceledRequest .getRunID ()))
960962 .setActivityId (canceledRequest .getActivityID ())
961963 .setDetails (payload (canceledRequest .getDetails ()))
962- .setIdentity (canceledRequest .getIdentity () != null ? canceledRequest .getIdentity () : "" );
964+ .setIdentity (
965+ canceledRequest .getIdentity () != null ? canceledRequest .getIdentity () : "" );
963966 return request .build ();
964967 }
965968
You can’t perform that action at this time.
0 commit comments