87
ctx context.Context,
88
request *persistence.InternalUpdateTaskQueueRequest,
90
>
nidBytes, err := primitives.ParseUUID(request.NamespaceID)
91
>
if err != nil {
92
return nil, serviceerror.NewInternal(err.Error())
93
}
94
95
>
tqId, tqHash := taskQueueIdAndHash(nidBytes, request.TaskQueue, request.TaskType, persistence.SubqueueZero)
task_queues.go
96
>
var resp *persistence.UpdateTaskQueueResponse
97
>
err = m.txExecute(ctx, "UpdateTaskQueue", func(tx sqlplugin.Tx) error {
98
>
if err := lockTaskQueue(ctx,
99
>
tx,
100
>
tqHash,
101
>
tqId,
102
>
request.PrevRangeID,
103
>
m.version,
104
>
); err != nil {
105
return err
106
}