// TODO: this logic should be more generic so that the first replication task
// in the new run doesn't have to be HistoryReplicationTask
var newRunID string
newRunTask := newWorkflowSnapshot.Tasks[tasks.CategoryReplication][0]
delete(newWorkflowSnapshot.Tasks, tasks.CategoryReplication)
switch task := newRunTask.(type) {
case *tasks.HistoryReplicationTask:
// Handle HistoryReplicationTask specifically