46
dbRecordVersion int64,
47
branchToken []byte,
49
>
snapshot := &p.WorkflowSnapshot{
50
>
ExecutionInfo: RandomExecutionInfo(namespaceID, workflowID, eventID, lastWriteVersion, branchToken),
51
>
ExecutionState: RandomExecutionState(runID, state, status, lastWriteVersion),
52
>
53
>
NextEventID: eventID + 1, // NOTE: RandomSnapshot generates a single history event, hence NextEventID is plus 1
54
>
55
>
ActivityInfos: RandomInt64ActivityInfoMap(),
56
>
TimerInfos: RandomStringTimerInfoMap(),
57
>
ChildExecutionInfos: RandomInt64ChildExecutionInfoMap(),
58
>
RequestCancelInfos: RandomInt64RequestCancelInfoMap(),
59
>
SignalInfos: RandomInt64SignalInfoMap(),
60
>
SignalRequestedIDs: map[string]struct{}{uuid.New().String(): {}},
61
>
ChasmNodes: RandomChasmNodeMap(),
62
>
63
>
Tasks: map[tasks.Category][]tasks.Task{
64
>
tasks.CategoryTransfer: {},
65
>
tasks.CategoryTimer: {},
66
>
tasks.CategoryReplication: {},
67
>
tasks.CategoryVisibility: {},
68
>
},
69
>
70
>
Condition: rand.Int63(),
71
>
DBRecordVersion: dbRecordVersion,
72
>
}
73
>
74
>
if branchToken == nil {
75
return snapshot, nil
76
}