2610
status enumspb.WorkflowExecutionStatus,
2611
dbRecordVersion int64,
2613
>
branchToken := RandomBranchToken(s.NamespaceID, s.WorkflowID, s.RunID, s.HistoryBranchUtil)
2614
>
snapshot, events := RandomSnapshot(
2615
>
s.T(),
2616
>
s.NamespaceID,
2617
>
s.WorkflowID,
2618
>
s.RunID,
2619
>
common.FirstEventID,
2620
>
lastWriteVersion,
2621
>
state,
2622
>
status,
2623
>
dbRecordVersion,
2624
>
branchToken,
2625
>
)
2626
>
_, err := s.ExecutionManager.CreateWorkflowExecution(s.Ctx, &p.CreateWorkflowExecutionRequest{
2627
>
ShardID: s.ShardID,
2628
>
RangeID: s.RangeID,
2629
>
Mode: p.CreateWorkflowModeBrandNew,
2630
>
2631
>
PreviousRunID: "",
2632
>
PreviousLastWriteVersion: 0,
2633
>
2634
>
ArchetypeID: chasm.WorkflowArchetypeID,
2635
>
2636
>
NewWorkflowSnapshot: *snapshot,
2637
>
NewWorkflowEvents: events,
2638
>
})
2639
>
s.NoError(err)
2640
>
return branchToken, snapshot, events
2641
>
}
2642
2643
func (s *ExecutionMutableStateSuite) CreateCHASMExecution(