151
}
152
153
>
func (s *TaskQueueSuite) TestUpdate_Sticky() {
task_queue.go
154
>
prevRangeID := rand.Int63()
155
>
_ = s.createTaskQueue(prevRangeID, enumspb.TASK_QUEUE_KIND_STICKY)
156
>
157
>
rangID := rand.Int63()
158
>
taskQueue := s.randomTaskQueueInfo(enumspb.TASK_QUEUE_KIND_STICKY)
159
>
_, err := s.taskManager.UpdateTaskQueue(s.ctx, &p.UpdateTaskQueueRequest{
160
>
RangeID: rangID,
161
>
TaskQueueInfo: taskQueue,
162
>
163
>
PrevRangeID: prevRangeID,
164
>
})
165
>
s.NoError(err)
166
>
167
>
s.assertEqualWithDB(rangID, taskQueue)
168
>
}
169
170
func (s *TaskQueueSuite) TestUpdate_Sticky_Conflict() {