81
}
82
83
>
func (s *matchingTaskSuite) TestInsert_Single_Fail_Duplicate() {
matching_task.go
84
>
queueID := shuffle.Bytes(testMatchingTaskTaskQueueID)
85
>
taskID := int64(1)
86
>
87
>
task := s.newRandomTasksRow(queueID, taskID)
88
>
result, err := s.store.InsertIntoTasks(newExecutionContext(), []sqlplugin.TasksRow{task})
89
>
s.NoError(err)
90
>
rowsAffected, err := result.RowsAffected()
91
>
s.NoError(err)
92
>
s.Equal(1, int(rowsAffected))
93
>
94
>
task = s.newRandomTasksRow(queueID, taskID)
95
>
_, err = s.store.InsertIntoTasks(newExecutionContext(), []sqlplugin.TasksRow{task})
96
>
s.Error(err) // TODO persistence layer should do proper error translation
97
>
}
98
99
func (s *matchingTaskSuite) TestInsert_Multiple_Fail_Duplicate() {