1577
ctx context.Context,
1578
scheduledEventID int64,
1580
>
ai, ok := ms.pendingActivityInfoIDs[scheduledEventID]
1581
>
if !ok {
1582
return nil, ErrMissingActivityInfo
1583
}
1584
1585
>
currentBranchToken, version, err := ms.getCurrentBranchTokenAndEventVersion(ai.ScheduledEventId)
mutable_state_impl.go
1586
>
if err != nil {
1587
return nil, err
1588
}
1590
>
ctx,
1591
>
ms.shard.GetShardID(),
1592
>
events.EventKey{
1593
>
NamespaceID: namespace.ID(ms.executionInfo.NamespaceId),
1594
>
WorkflowID: ms.executionInfo.WorkflowId,
1595
>
RunID: ms.executionState.RunId,
1596
>
EventID: ai.ScheduledEventId,
1597
>
Version: version,
1598
>
},
1599
>
ai.ScheduledEventBatchId,
1600
>
currentBranchToken,
1601
>
)
1602
>
if err != nil {
1603
if common.IsNotFoundError(err) {
1604
// do not return the original error