92
}
93
94
>
func (s *TaskQueueSuite) TestCreate_Normal_Dup() {
task_queue.go
95
>
rangID := rand.Int63()
96
>
taskQueue := s.createTaskQueue(rangID, enumspb.TASK_QUEUE_KIND_NORMAL)
97
>
98
>
_, err := s.taskManager.CreateTaskQueue(s.ctx, &p.CreateTaskQueueRequest{
99
>
RangeID: rangID,
100
>
TaskQueueInfo: s.randomTaskQueueInfo(enumspb.TASK_QUEUE_KIND_NORMAL),
101
>
})
102
>
s.IsType(&p.ConditionFailedError{}, err)
103
>
104
>
s.assertEqualWithDB(rangID, taskQueue)
105
>
}
106
107
func (s *TaskQueueSuite) TestCreate_Sticky_Dup() {