oldRangeID int64,
v sqlplugin.MatchingTaskVersion,
rangeID, err := tx.LockTaskQueues(ctx, sqlplugin.TaskQueuesFilter{
RangeHash: tqHash,
TaskQueueID: tqId,
}, v)
switch err {
case nil:
if rangeID != oldRangeID {
return &persistence.ConditionFailedError{
Msg: fmt.Sprintf("Task queue range ID was %v when it was should have been %v", rangeID, oldRangeID),