157
ctx context.Context,
158
request *p.InternalGetTaskQueueRequest,
160
>
query := d.Session.Query(switchTasksTable(templateGetTaskQueueQuery, d.version),
161
>
request.NamespaceID,
162
>
request.TaskQueue,
163
>
request.TaskType,
164
>
rowTypeTaskQueue,
165
>
taskQueueTaskID,
166
>
).WithContext(ctx)
167
>
168
>
var rangeID int64
169
>
var tlBytes []byte
170
>
var tlEncoding string
171
>
if err := query.Scan(&rangeID, &tlBytes, &tlEncoding); err != nil {
172
return nil, gocql.ConvertError("GetTaskQueue", err)
173
}