105
}
106
107
>
func (s *TaskQueueSuite) TestCreate_Sticky_Dup() {
task_queue.go
108
>
rangID := rand.Int63()
109
>
taskQueue := s.createTaskQueue(rangID, enumspb.TASK_QUEUE_KIND_STICKY)
110
>
111
>
_, err := s.taskManager.CreateTaskQueue(s.ctx, &p.CreateTaskQueueRequest{
112
>
RangeID: rangID,
113
>
TaskQueueInfo: s.randomTaskQueueInfo(enumspb.TASK_QUEUE_KIND_STICKY),
114
>
})
115
>
s.IsType(&p.ConditionFailedError{}, err)
116
>
117
>
s.assertEqualWithDB(rangID, taskQueue)
118
>
}
119
120
func (s *TaskQueueSuite) TestUpdate_Normal() {