177
versionedTransition *persistencespb.VersionedTransition,
178
isStateBased bool,
180
>
181
>
versionHistory := &historyspb.VersionHistory{
182
>
BranchToken: nil,
183
>
Items: versionHistoryItems,
184
>
}
185
>
186
>
firstBlob := eventsSlice[0]
187
>
lastBlob := eventsSlice[len(eventsSlice)-1]
188
>
189
>
firstEvent := firstBlob[0]
190
>
lastEvent := lastBlob[len(lastBlob)-1]
191
>
version := firstEvent.GetVersion()
192
>
193
>
sourceCluster := clusterMetadata.ClusterNameForFailoverVersion(true, version)
194
>
195
>
eventTime := time.Time{}
196
>
for _, events := range eventsSlice {
197
>
for _, event := range events {
198
>
eventTime = util.MaxTime(eventTime, timestamp.TimeValue(event.GetEventTime()))
199
>
}
200
}
202
eventTime = util.MaxTime(eventTime, timestamp.TimeValue(event.GetEventTime()))
203
}
204
206
// This is for backward compatibility, old replication tasks generated for continuedAsNew case
207
// doesn't have newRunID field set. In that case, we need to get newRunID from the last event.