1002
t.NewRunID = newRunID
1003
return true
1004
>
case *tasks.SyncVersionedTransitionTask:
context.go
1005
>
t.NewRunID = newRunID
1006
>
taskEquivalents := t.TaskEquivalents
1007
>
taskEquivalentsUpdated := false
1008
>
for idx := len(taskEquivalents) - 1; idx >= 0; idx-- {
1009
>
// For state based, we should update a sync versioned transition task and update a history task inside task equivalent.
1010
>
if historyTask, ok := taskEquivalents[idx].(*tasks.HistoryReplicationTask); ok {
1011
>
historyTask.NewRunBranchToken = newRunBranchToken
1012
>
historyTask.NewRunID = newRunID
1013
>
taskEquivalentsUpdated = true
1014
>
break
1015
}
1016
}
1018
c.logger.Error("SyncVersionedTransitionTask has no HistoryReplicationTask equivalent to update")
1019
}
1021
default:
1022
}