89
}
90
92
>
queueID := shuffle.Bytes(testMatchingTaskTaskQueueID)
93
>
rangeID := int64(1)
94
>
95
>
taskQueue := s.newRandomTasksQueueRow(queueID, rangeID)
96
>
result, err := s.store.InsertIntoTaskQueues(newExecutionContext(), &taskQueue, s.version)
97
>
s.NoError(err)
98
>
rowsAffected, err := result.RowsAffected()
99
>
s.NoError(err)
100
>
s.Equal(1, int(rowsAffected))
101
>
102
>
filter := sqlplugin.TaskQueuesFilter{
103
>
RangeHash: testMatchingTaskQueueRangeHash,
104
>
TaskQueueID: queueID,
105
>
}
106
>
rows, err := s.store.SelectFromTaskQueues(newExecutionContext(), filter, s.version)
107
>
s.NoError(err)
108
>
s.Equal([]sqlplugin.TaskQueuesRow{taskQueue}, rows)
109
>
}
110
111
func (s *matchingTaskQueueSuite) TestInsertUpdate_Success() {