78
}
79
81
>
rangeID := rand.Int63()
82
>
taskQueue := s.createTaskQueue(rangeID)
83
>
84
>
taskID := rand.Int63()
85
>
task := s.randomTask(taskID)
86
>
_, err := s.taskManager.CreateTasks(s.ctx, &p.CreateTasksRequest{
87
>
TaskQueueInfo: &p.PersistedTaskQueueInfo{
88
>
RangeID: rand.Int63(),
89
>
Data: taskQueue,
90
>
},
91
>
Tasks: []*persistencespb.AllocatedTaskInfo{task},
92
>
})
93
>
s.IsType(&p.ConditionFailedError{}, err)
94
>
95
>
resp, err := s.taskManager.GetTasks(s.ctx, &p.GetTasksRequest{
96
>
NamespaceID: s.namespaceID,
97
>
TaskQueue: s.taskQueueName,
98
>
TaskType: s.taskQueueType,
99
>
InclusiveMinTaskID: taskID,
100
>
ExclusiveMaxTaskID: taskID + 1,
101
>
PageSize: 100,
102
>
NextPageToken: nil,
103
>
})
104
>
s.NoError(err)
105
>
protorequire.ProtoSliceEqual(s.T(), []*persistencespb.AllocatedTaskInfo{}, resp.Tasks)
106
>
s.Nil(resp.NextPageToken)
107
>
}
108
109
func (s *TaskQueueTaskSuite) TestCreateGet_One() {