Skip to content

Commit 03cfb7a

Browse files
authored
fix gRPC type mappers (#728)
1 parent b485146 commit 03cfb7a

File tree

1 file changed

+0
-34
lines changed

1 file changed

+0
-34
lines changed

src/main/java/com/uber/cadence/internal/compatibility/proto/TypeMapper.java

Lines changed: 0 additions & 34 deletions
Original file line numberDiff line numberDiff line change
@@ -494,26 +494,6 @@ static ParentExecutionInfo parentExecutionInfo(
494494
.build();
495495
}
496496

497-
static PendingActivityInfo pendingActivityInfo(com.uber.cadence.PendingActivityInfo t) {
498-
if (t == null) {
499-
return null;
500-
}
501-
return PendingActivityInfo.newBuilder()
502-
.setActivityId(t.getActivityID())
503-
.setActivityType(activityType(t.getActivityType()))
504-
.setState(EnumMapper.pendingActivityState(t.getState()))
505-
.setHeartbeatDetails(payload(t.getHeartbeatDetails()))
506-
.setLastHeartbeatTime(unixNanoToTime(t.getLastHeartbeatTimestamp()))
507-
.setLastStartedTime(unixNanoToTime(t.getLastStartedTimestamp()))
508-
.setAttempt(t.getAttempt())
509-
.setMaximumAttempts(t.getMaximumAttempts())
510-
.setScheduledTime(unixNanoToTime(t.getScheduledTimestamp()))
511-
.setExpirationTime(unixNanoToTime(t.getExpirationTimestamp()))
512-
.setLastFailure(failure(t.getLastFailureReason(), t.getLastFailureDetails()))
513-
.setLastWorkerIdentity(t.getLastWorkerIdentity())
514-
.build();
515-
}
516-
517497
static PendingChildExecutionInfo pendingChildExecutionInfo(
518498
com.uber.cadence.PendingChildExecutionInfo t) {
519499
if (t == null) {
@@ -527,20 +507,6 @@ static PendingChildExecutionInfo pendingChildExecutionInfo(
527507
.build();
528508
}
529509

530-
static ActivityLocalDispatchInfo activityLocalDispatchInfo(
531-
com.uber.cadence.ActivityLocalDispatchInfo t) {
532-
if (t == null) {
533-
return null;
534-
}
535-
return ActivityLocalDispatchInfo.newBuilder()
536-
.setActivityId(t.getActivityId())
537-
.setScheduledTime(unixNanoToTime(t.getScheduledTimestamp()))
538-
.setStartedTime(unixNanoToTime(t.getStartedTimestamp()))
539-
.setScheduledTimeOfThisAttempt(unixNanoToTime(t.getScheduledTimestampOfThisAttempt()))
540-
.setTaskToken(arrayToByteString(t.getTaskToken()))
541-
.build();
542-
}
543-
544510
static TaskListPartitionMetadata taskListPartitionMetadata(
545511
com.uber.cadence.TaskListPartitionMetadata t) {
546512
if (t == null) {

0 commit comments

Comments
 (0)