1720
ctx context.Context,
1721
initiatedEventID int64,
1723
>
ri, ok := ms.pendingRequestCancelInfoIDs[initiatedEventID]
1724
>
if !ok {
1725
return nil, ErrMissingRequestCancelInfo
1726
}
1727
1728
>
currentBranchToken, version, err := ms.getCurrentBranchTokenAndEventVersion(ri.InitiatedEventId)
mutable_state_impl.go
1729
>
if err != nil {
1730
return nil, err
1731
}
1733
>
ctx,
1734
>
ms.shard.GetShardID(),
1735
>
events.EventKey{
1736
>
NamespaceID: namespace.ID(ms.executionInfo.NamespaceId),
1737
>
WorkflowID: ms.executionInfo.WorkflowId,
1738
>
RunID: ms.executionState.RunId,
1739
>
EventID: ri.InitiatedEventId,
1740
>
Version: version,
1741
>
},
1742
>
ri.InitiatedEventBatchId,
1743
>
currentBranchToken,
1744
>
)
1745
>
if err != nil {
1746
if common.IsNotFoundError(err) {
1747
// do not return the original error