1674
ctx context.Context,
1675
initiatedEventID int64,
1677
>
ci, ok := ms.pendingChildExecutionInfoIDs[initiatedEventID]
1678
>
if !ok {
1679
return nil, ErrMissingChildWorkflowInfo
1680
}
1681
1682
>
currentBranchToken, version, err := ms.getCurrentBranchTokenAndEventVersion(ci.InitiatedEventId)
mutable_state_impl.go
1683
>
if err != nil {
1684
return nil, err
1685
}
1687
>
ctx,
1688
>
ms.shard.GetShardID(),
1689
>
events.EventKey{
1690
>
NamespaceID: namespace.ID(ms.executionInfo.NamespaceId),
1691
>
WorkflowID: ms.executionInfo.WorkflowId,
1692
>
RunID: ms.executionState.RunId,
1693
>
EventID: ci.InitiatedEventId,
1694
>
Version: version,
1695
>
},
1696
>
ci.InitiatedEventBatchId,
1697
>
currentBranchToken,
1698
>
)
1699
>
if err != nil {
1700
if common.IsNotFoundError(err) {
1701
// do not return the original error