1800
ctx context.Context,
1801
initiatedEventID int64,
1803
>
si, ok := ms.pendingSignalInfoIDs[initiatedEventID]
1804
>
if !ok {
1805
return nil, ErrMissingSignalInfo
1806
}
1807
1808
>
currentBranchToken, version, err := ms.getCurrentBranchTokenAndEventVersion(si.InitiatedEventId)
mutable_state_impl.go
1809
>
if err != nil {
1810
return nil, err
1811
}
1813
>
ctx,
1814
>
ms.shard.GetShardID(),
1815
>
events.EventKey{
1816
>
NamespaceID: namespace.ID(ms.executionInfo.NamespaceId),
1817
>
WorkflowID: ms.executionInfo.WorkflowId,
1818
>
RunID: ms.executionState.RunId,
1819
>
EventID: si.InitiatedEventId,
1820
>
Version: version,
1821
>
},
1822
>
si.InitiatedEventBatchId,
1823
>
currentBranchToken,
1824
>
)
1825
>
if err != nil {
1826
if common.IsNotFoundError(err) {
1827
// do not return the original error