2160
}
2161
2163
>
branchToken, snapshot, events := s.CreateWorkflow(
2164
>
rand.Int63(),
2165
>
enumsspb.WORKFLOW_EXECUTION_STATE_CREATED,
2166
>
enumspb.WORKFLOW_EXECUTION_STATUS_RUNNING,
2167
>
rand.Int63(),
2168
>
)
2169
>
2170
>
setSnapshot, _ := RandomSnapshot(
2171
>
s.T(),
2172
>
s.NamespaceID,
2173
>
s.WorkflowID,
2174
>
s.RunID,
2175
>
common.FirstEventID,
2176
>
rand.Int63(),
2177
>
enumsspb.WORKFLOW_EXECUTION_STATE_RUNNING,
2178
>
enumspb.WORKFLOW_EXECUTION_STATUS_RUNNING,
2179
>
snapshot.DBRecordVersion+1,
2180
>
branchToken,
2181
>
)
2182
>
_, err := s.ExecutionManager.SetWorkflowExecution(s.Ctx, &p.SetWorkflowExecutionRequest{
2183
>
ShardID: s.ShardID,
2184
>
RangeID: s.RangeID,
2185
>
2186
>
ArchetypeID: chasm.WorkflowArchetypeID,
2187
>
2188
>
SetWorkflowSnapshot: *setSnapshot,
2189
>
})
2190
>
s.NoError(err)
2191
>
2192
>
s.AssertMSEqualWithDB(chasm.WorkflowArchetypeID, setSnapshot)
2193
>
s.AssertHEEqualWithDB(branchToken, events)
2194
>
}
2195
2196
func (s *ExecutionMutableStateSuite) TestSet_CHASM() {