135
}
136
137
>
func (s *TaskQueueSuite) TestUpdate_Normal_Conflict() {
task_queue.go
138
>
prevRangeID := rand.Int63()
139
>
taskQueue := s.createTaskQueue(prevRangeID, enumspb.TASK_QUEUE_KIND_NORMAL)
140
>
141
>
rangID := rand.Int63()
142
>
_, err := s.taskManager.UpdateTaskQueue(s.ctx, &p.UpdateTaskQueueRequest{
143
>
RangeID: rangID,
144
>
TaskQueueInfo: s.randomTaskQueueInfo(enumspb.TASK_QUEUE_KIND_NORMAL),
145
>
146
>
PrevRangeID: rand.Int63(),
147
>
})
148
>
s.IsType(&p.ConditionFailedError{}, err)
149
>
150
>
s.assertEqualWithDB(prevRangeID, taskQueue)
151
>
}
152
153
func (s *TaskQueueSuite) TestUpdate_Sticky() {