feat(domain multi-tenancy): Pull latest idl changes

Author: Shaddoll

.gen/go/shared/shared.go

@@ -1574,6 +1574,14 @@ func (t *TransferTaskInfo) GetVisibilityTimestamp() time.Time {
 	return time.Unix(0, 0)
 }
 
+// GetOriginalTaskList internal sql blob getter
+func (t *TransferTaskInfo) GetOriginalTaskList() (o string) {
+	if t != nil {
+		return t.OriginalTaskList
+	}
+	return
+}
+
 // GetDomainID internal sql blob getter
 func (t *TimerTaskInfo) GetDomainID() (o []byte) {
 	if t != nil && t.DomainID != nil {
@@ -1638,6 +1646,14 @@ func (t *TimerTaskInfo) GetEventID() (o int64) {
 	return
 }
 
+// GetTaskList internal sql blob getter
+func (t *TimerTaskInfo) GetTaskList() (o string) {
+	if t != nil {
+		return t.TaskList
+	}
+	return
+}
+
 // GetDomainID internal sql blob getter
 func (t *ReplicationTaskInfo) GetDomainID() (o []byte) {
 	if t != nil {

.gen/go/sqlblobs/sqlblobs.go

@@ -115,6 +115,7 @@ var expectedNil = map[string]map[string]any{
 		"GetScheduleID":              int64(0),
 		"GetVersion":                 int64(0),
 		"GetVisibilityTimestamp":     zeroUnix,
+		"GetOriginalTaskList":        "",
 	},
 	"*serialization.TimerTaskInfo": {
 		"GetDomainID":        []uint8(nil),
@@ -125,6 +126,7 @@ var expectedNil = map[string]map[string]any{
 		"GetTimeoutType":     int16(0),
 		"GetVersion":         int64(0),
 		"GetWorkflowID":      "",
+		"GetTaskList":        "",
 	},
 	"*serialization.ReplicationTaskInfo": {
 		"GetBranchToken":             []uint8(nil),
@@ -360,6 +362,7 @@ var expectedEmpty = map[string]map[string]any{
 		"GetScheduleID":              int64(0),
 		"GetVersion":                 int64(0),
 		"GetVisibilityTimestamp":     time.Time{},
+		"GetOriginalTaskList":        "",
 	},
 	"*serialization.TimerTaskInfo": {
 		"GetDomainID":        []uint8(nil),
@@ -370,6 +373,7 @@ var expectedEmpty = map[string]map[string]any{
 		"GetTimeoutType":     int16(0),
 		"GetVersion":         int64(0),
 		"GetWorkflowID":      "",
+		"GetTaskList":        "",
 	},
 	"*serialization.ReplicationTaskInfo": {
 		"GetBranchToken":             []uint8(nil),
@@ -607,6 +611,7 @@ var expectedNonEmpty = map[string]map[string]any{
 		"GetScheduleID":              int64(2),
 		"GetVersion":                 int64(3),
 		"GetVisibilityTimestamp":     taskInfoCreateTime,
+		"GetOriginalTaskList":        "originalTaskList",
 	},
 	"*serialization.TimerTaskInfo": {
 		"GetDomainID":        []byte(taskDomainID),
@@ -617,6 +622,7 @@ var expectedNonEmpty = map[string]map[string]any{
 		"GetTimeoutType":     int16(2),
 		"GetVersion":         int64(3),
 		"GetWorkflowID":      "workflowID",
+		"GetTaskList":        "taskList",
 	},
 	"*serialization.ReplicationTaskInfo": {
 		"GetBranchToken":             []byte("branchToken"),

.gen/proto/history/v1/service.pb.yarpc.go

@@ -165,6 +165,7 @@ func TestGettersForInfos(t *testing.T) {
 			ScheduleID:              2,
 			Version:                 3,
 			VisibilityTimestamp:     taskInfoCreateTime,
+			OriginalTaskList:        "originalTaskList",
 		},
 		&TimerTaskInfo{
 			DomainID:        taskDomainID,
@@ -175,6 +176,7 @@ func TestGettersForInfos(t *testing.T) {
 			Version:         3,
 			ScheduleAttempt: 4,
 			EventID:         5,
+			TaskList:        "taskList",
 		},
 		&ReplicationTaskInfo{
 			DomainID:                replicationTaskDomainID,

.gen/proto/matching/v1/service.pb.yarpc.go

@@ -304,6 +304,7 @@ type (
 		ScheduleID              int64
 		Version                 int64
 		VisibilityTimestamp     time.Time
+		OriginalTaskList        string
 	}
 
 	// CrossClusterTaskInfo blob in a serialization agnostic format
@@ -323,6 +324,7 @@ type (
 		Version         int64
 		ScheduleAttempt int64
 		EventID         int64
+		TaskList        string
 	}
 
 	// ReplicationTaskInfo blob in a serialization agnostic format

common/persistence/serialization/getters.go

@@ -684,6 +684,7 @@ func transferTaskInfoToThrift(info *TransferTaskInfo) *sqlblobs.TransferTaskInfo
 		ScheduleID:               &info.ScheduleID,
 		Version:                  &info.Version,
 		VisibilityTimestampNanos: timeToUnixNanoPtr(info.VisibilityTimestamp),
+		OriginalTaskList:         &info.OriginalTaskList,
 	}
 	if len(info.TargetDomainIDs) > 0 {
 		thriftTaskInfo.TargetDomainIDs = [][]byte{}
@@ -712,6 +713,7 @@ func transferTaskInfoFromThrift(info *sqlblobs.TransferTaskInfo) *TransferTaskIn
 		ScheduleID:              info.GetScheduleID(),
 		Version:                 info.GetVersion(),
 		VisibilityTimestamp:     timeFromUnixNano(info.GetVisibilityTimestampNanos()),
+		OriginalTaskList:        info.GetOriginalTaskList(),
 	}
 	if len(info.GetTargetDomainIDs()) > 0 {
 		transferTaskInfo.TargetDomainIDs = []UUID{}
@@ -743,6 +745,7 @@ func timerTaskInfoToThrift(info *TimerTaskInfo) *sqlblobs.TimerTaskInfo {
 		Version:         &info.Version,
 		ScheduleAttempt: &info.ScheduleAttempt,
 		EventID:         &info.EventID,
+		TaskList:        &info.TaskList,
 	}
 }
 
@@ -759,6 +762,7 @@ func timerTaskInfoFromThrift(info *sqlblobs.TimerTaskInfo) *TimerTaskInfo {
 		Version:         info.GetVersion(),
 		ScheduleAttempt: info.GetScheduleAttempt(),
 		EventID:         info.GetEventID(),
+		TaskList:        info.GetTaskList(),
 	}
 }
 

common/persistence/serialization/getters_fixtures_test.go

@@ -541,6 +541,7 @@ func TestTransferTaskInfo(t *testing.T) {
 		TargetChildWorkflowOnly: true,
 		ScheduleID:              int64(rand.Intn(1000)),
 		Version:                 int64(rand.Intn(1000)),
+		OriginalTaskList:        "OriginalTaskList",
 	}
 	actual := transferTaskInfoFromThrift(transferTaskInfoToThrift(expected))
 	assert.Equal(t, expected, actual)
@@ -558,6 +559,7 @@ func TestTimerTaskInfo(t *testing.T) {
 		Version:         int64(rand.Intn(1000)),
 		ScheduleAttempt: int64(rand.Intn(1000)),
 		EventID:         int64(rand.Intn(1000)),
+		TaskList:        "TaskList",
 	}
 	actual := timerTaskInfoFromThrift(timerTaskInfoToThrift(expected))
 	assert.Equal(t, expected, actual)