168
}
169
170
>
func (s *TaskQueueSuite) TestUpdate_Sticky_Conflict() {
task_queue.go
171
>
prevRangeID := rand.Int63()
172
>
taskQueue := s.createTaskQueue(prevRangeID, enumspb.TASK_QUEUE_KIND_STICKY)
173
>
174
>
rangID := rand.Int63()
175
>
_, err := s.taskManager.UpdateTaskQueue(s.ctx, &p.UpdateTaskQueueRequest{
176
>
RangeID: rangID,
177
>
TaskQueueInfo: s.randomTaskQueueInfo(enumspb.TASK_QUEUE_KIND_STICKY),
178
>
179
>
PrevRangeID: rand.Int63(),
180
>
})
181
>
s.IsType(&p.ConditionFailedError{}, err)
182
>
183
>
s.assertEqualWithDB(prevRangeID, taskQueue)
184
>
}
185
186
func (s *TaskQueueSuite) TestDelete() {