118
}
119
120
>
func (s *TaskQueueSuite) TestUpdate_Normal() {
task_queue.go
121
>
prevRangeID := rand.Int63()
122
>
_ = s.createTaskQueue(prevRangeID, enumspb.TASK_QUEUE_KIND_NORMAL)
123
>
124
>
rangID := rand.Int63()
125
>
taskQueue := s.randomTaskQueueInfo(enumspb.TASK_QUEUE_KIND_NORMAL)
126
>
_, err := s.taskManager.UpdateTaskQueue(s.ctx, &p.UpdateTaskQueueRequest{
127
>
RangeID: rangID,
128
>
TaskQueueInfo: taskQueue,
129
>
130
>
PrevRangeID: prevRangeID,
131
>
})
132
>
s.NoError(err)
133
>
134
>
s.assertEqualWithDB(rangID, taskQueue)
135
>
}
136
137
func (s *TaskQueueSuite) TestUpdate_Normal_Conflict() {