Improve definition for cross-cluster related endpoints (cadence-workf…

…low#4294)
syllogy · Jul 2, 2021 · 6964885 · 6964885
1 parent 17663af
commit 6964885
Show file tree

Hide file tree

Showing 19 changed files with 2,277 additions and 1,179 deletions.
diff --git a/.gen/go/shared/shared.go b/.gen/go/shared/shared.go
diff --git a/.gen/proto/admin/v1/service.pb.go b/.gen/proto/admin/v1/service.pb.go
diff --git a/.gen/proto/admin/v1/service.pb.yarpc.go b/.gen/proto/admin/v1/service.pb.yarpc.go
diff --git a/.gen/proto/history/v1/service.pb.go b/.gen/proto/history/v1/service.pb.go
diff --git a/.gen/proto/history/v1/service.pb.yarpc.go b/.gen/proto/history/v1/service.pb.yarpc.go
diff --git a/.gen/proto/shared/v1/queue.pb.go b/.gen/proto/shared/v1/queue.pb.go
diff --git a/.gen/proto/shared/v1/queue.pb.yarpc.go b/.gen/proto/shared/v1/queue.pb.yarpc.go
diff --git a/common/types/mapper/proto/admin.go b/common/types/mapper/proto/admin.go
@@ -705,7 +705,8 @@ func FromAdminGetCrossClusterTasksResponse(t *types.GetCrossClusterTasksResponse
 		return nil
 	}
 	return &adminv1.GetCrossClusterTasksResponse{
-		TasksByShard: FromCrossClusterTaskRequestMap(t.TasksByShard),
+		TasksByShard:       FromCrossClusterTaskRequestMap(t.TasksByShard),
+		FailedCauseByShard: FromGetTaskFailedCauseMap(t.FailedCauseByShard),
 	}
 }
 
@@ -715,6 +716,7 @@ func ToAdminGetCrossClusterTasksResponse(t *adminv1.GetCrossClusterTasksResponse
 		return nil
 	}
 	return &types.GetCrossClusterTasksResponse{
-		TasksByShard: ToCrossClusterTaskRequestMap(t.TasksByShard),
+		TasksByShard:       ToCrossClusterTaskRequestMap(t.TasksByShard),
+		FailedCauseByShard: ToGetTaskFailedCauseMap(t.FailedCauseByShard),
 	}
 }
diff --git a/common/types/mapper/proto/history.go b/common/types/mapper/proto/history.go
@@ -1419,7 +1419,8 @@ func FromHistoryGetCrossClusterTasksResponse(t *types.GetCrossClusterTasksRespon
 		return nil
 	}
 	return &historyv1.GetCrossClusterTasksResponse{
-		TasksByShard: FromCrossClusterTaskRequestMap(t.TasksByShard),
+		TasksByShard:       FromCrossClusterTaskRequestMap(t.TasksByShard),
+		FailedCauseByShard: FromGetTaskFailedCauseMap(t.FailedCauseByShard),
 	}
 }
 
@@ -1429,7 +1430,8 @@ func ToHistoryGetCrossClusterTasksResponse(t *historyv1.GetCrossClusterTasksResp
 		return nil
 	}
 	return &types.GetCrossClusterTasksResponse{
-		TasksByShard: ToCrossClusterTaskRequestMap(t.TasksByShard),
+		TasksByShard:       ToCrossClusterTaskRequestMap(t.TasksByShard),
+		FailedCauseByShard: ToGetTaskFailedCauseMap(t.FailedCauseByShard),
 	}
 }
 
@@ -1442,6 +1444,7 @@ func FromHistoryRespondCrossClusterTasksCompletedRequest(t *types.RespondCrossCl
 		ShardId:       t.ShardID,
 		TargetCluster: t.TargetCluster,
 		TaskResponses: FromCrossClusterTaskResponseArray(t.TaskResponses),
+		FetchNewTasks: t.FetchNewTasks,
 	}
 }
 
@@ -1454,6 +1457,7 @@ func ToHistoryRespondCrossClusterTasksCompletedRequest(t *historyv1.RespondCross
 		ShardID:       t.ShardId,
 		TargetCluster: t.TargetCluster,
 		TaskResponses: ToCrossClusterTaskResponseArray(t.TaskResponses),
+		FetchNewTasks: t.FetchNewTasks,
 	}
 }