109
}
110
112
>
queueID := shuffle.Bytes(testMatchingTaskTaskQueueID)
113
>
rangeID := int64(1)
114
>
115
>
taskQueue := s.newRandomTasksQueueRow(queueID, rangeID)
116
>
rangeID++
117
>
result, err := s.store.InsertIntoTaskQueues(newExecutionContext(), &taskQueue, s.version)
118
>
s.NoError(err)
119
>
rowsAffected, err := result.RowsAffected()
120
>
s.NoError(err)
121
>
s.Equal(1, int(rowsAffected))
122
>
123
>
taskQueue = s.newRandomTasksQueueRow(queueID, rangeID)
124
>
result, err = s.store.UpdateTaskQueues(newExecutionContext(), &taskQueue, s.version)
125
>
s.NoError(err)
126
>
rowsAffected, err = result.RowsAffected()
127
>
s.NoError(err)
128
>
s.Equal(1, int(rowsAffected))
129
>
}
130
131
func (s *matchingTaskQueueSuite) TestUpdate_Fail() {