50
ctx context.Context,
51
request *persistence.InternalGetTaskQueueRequest,
52
>
) (*persistence.InternalGetTaskQueueResponse, error) {
task_queues.go
53
>
nidBytes, err := primitives.ParseUUID(request.NamespaceID)
54
>
if err != nil {
55
return nil, serviceerror.NewInternal(err.Error())
56
}
57
>
tqId, tqHash := taskQueueIdAndHash(nidBytes, request.TaskQueue, request.TaskType, persistence.SubqueueZero)
task_queues.go
58
>
rows, err := m.DB.SelectFromTaskQueues(ctx, sqlplugin.TaskQueuesFilter{
59
>
RangeHash: tqHash,
60
>
TaskQueueID: tqId,
61
>
}, m.version)
62
>
63
>
switch err {
64
case nil:
65
if len(rows) != 1 {