677
forkNodeID int64,
678
resetRunID string,
680
>
// fork a new history branch
681
>
shardID := r.shardContext.GetShardID()
682
>
resp, err := r.executionMgr.ForkHistoryBranch(ctx, &persistence.ForkHistoryBranchRequest{
683
>
ForkBranchToken: forkBranchToken,
684
>
ForkNodeID: forkNodeID,
685
>
Info: persistence.BuildHistoryGarbageCleanupInfo(namespaceID.String(), workflowID, resetRunID),
686
>
ShardID: shardID,
687
>
NamespaceID: namespaceID.String(),
688
>
NewRunID: resetRunID,
689
>
})
690
>
if err != nil {
691
return nil, err
692
}
693
695
}
696