117
}
118
120
>
queueID := shuffle.Bytes(testMatchingTaskTaskQueueID)
121
>
taskID := int64(100)
122
>
123
>
task := s.newRandomTasksRow(queueID, taskID)
124
>
result, err := s.store.InsertIntoTasks(newExecutionContext(), []sqlplugin.TasksRow{task})
125
>
s.NoError(err)
126
>
rowsAffected, err := result.RowsAffected()
127
>
s.NoError(err)
128
>
s.Equal(1, int(rowsAffected))
129
>
130
>
inclusiveMinTaskID := new(taskID)
131
>
exclusiveMaxTaskID := new(taskID + 1)
132
>
pageSize := new(1)
133
>
filter := sqlplugin.TasksFilter{
134
>
RangeHash: testMatchingTaskRangeHash,
135
>
TaskQueueID: queueID,
136
>
InclusiveMinTaskID: inclusiveMinTaskID,
137
>
ExclusiveMaxTaskID: exclusiveMaxTaskID,
138
>
PageSize: pageSize,
139
>
}
140
>
rows, err := s.store.SelectFromTasks(newExecutionContext(), filter)
141
>
s.NoError(err)
142
>
// fill in some omitted info
143
>
for index := range rows {
144
>
rows[index].RangeHash = testMatchingTaskRangeHash
145
>
rows[index].TaskQueueID = queueID
146
>
}
147
>
s.Equal([]sqlplugin.TasksRow{task}, rows)
148
}
149