73
}
74
76
>
queueID := shuffle.Bytes(testMatchingTaskTaskQueueID)
77
>
rangeID := int64(1)
78
>
79
>
taskQueue := s.newRandomTasksQueueRow(queueID, rangeID)
80
>
result, err := s.store.InsertIntoTaskQueues(newExecutionContext(), &taskQueue, s.version)
81
>
s.NoError(err)
82
>
rowsAffected, err := result.RowsAffected()
83
>
s.NoError(err)
84
>
s.Equal(1, int(rowsAffected))
85
>
86
>
taskQueue = s.newRandomTasksQueueRow(queueID, rangeID)
87
>
_, err = s.store.InsertIntoTaskQueues(newExecutionContext(), &taskQueue, s.version)
88
>
s.Error(err) // TODO persistence layer should do proper error translation
89
>
}
90
91
func (s *matchingTaskQueueSuite) TestInsertSelect() {