2099
}
2100
2102
>
branchToken := RandomBranchToken(s.NamespaceID, s.WorkflowID, s.RunID, s.HistoryBranchUtil)
2103
>
setSnapshot, _ := RandomSnapshot(
2104
>
s.T(),
2105
>
s.NamespaceID,
2106
>
s.WorkflowID,
2107
>
s.RunID,
2108
>
rand.Int63(),
2109
>
rand.Int63(),
2110
>
enumsspb.WORKFLOW_EXECUTION_STATE_RUNNING,
2111
>
enumspb.WORKFLOW_EXECUTION_STATUS_RUNNING,
2112
>
rand.Int63(),
2113
>
branchToken,
2114
>
)
2115
>
_, err := s.ExecutionManager.SetWorkflowExecution(s.Ctx, &p.SetWorkflowExecutionRequest{
2116
>
ShardID: s.ShardID,
2117
>
RangeID: s.RangeID,
2118
>
2119
>
ArchetypeID: chasm.WorkflowArchetypeID,
2120
>
2121
>
SetWorkflowSnapshot: *setSnapshot,
2122
>
})
2123
>
s.IsType(&p.ConditionFailedError{}, err)
2124
>
2125
>
s.AssertMissingFromDB(s.NamespaceID, s.WorkflowID, s.RunID, chasm.WorkflowArchetypeID)
2126
>
}
2127
2128
func (s *ExecutionMutableStateSuite) TestSet_Conflict() {