206
}
207
208
>
func (s *TaskQueueSuite) TestDelete_Conflict() {
task_queue.go
209
>
rangeID := rand.Int63()
210
>
taskQueue := s.createTaskQueue(
211
>
rangeID,
212
>
enumspb.TaskQueueKind(rand.Int31n(
213
>
int32(len(enumspb.TaskQueueKind_value))+1),
214
>
),
215
>
)
216
>
217
>
err := s.taskManager.DeleteTaskQueue(s.ctx, &p.DeleteTaskQueueRequest{
218
>
TaskQueue: &p.TaskQueueKey{
219
>
NamespaceID: taskQueue.NamespaceId,
220
>
TaskQueueName: taskQueue.Name,
221
>
TaskQueueType: taskQueue.TaskType,
222
>
},
223
>
RangeID: rand.Int63(),
224
>
})
225
>
s.IsType(&p.ConditionFailedError{}, err)
226
>
227
>
s.assertEqualWithDB(rangeID, taskQueue)
228
>
}
229
230
func (s *TaskQueueSuite) TesList() {