}
queueID := shuffle.Bytes(testMatchingTaskTaskQueueID)
taskID := int64(1)
task := s.newRandomTasksRow(queueID, taskID)
result, err := s.store.InsertIntoTasks(newExecutionContext(), []sqlplugin.TasksRow{task})
s.NoError(err)
rowsAffected, err := result.RowsAffected()
s.NoError(err)
s.Equal(1, int(rowsAffected))
}
func (s *matchingTaskSuite) TestInsert_Multiple_Success() {