85
}
86
88
>
shardID := rand.Int31()
89
>
timestamp := s.now()
90
>
taskID := int64(1)
91
>
92
>
task := s.newRandomTimerTaskRow(shardID, timestamp, taskID)
93
>
result, err := s.store.InsertIntoTimerTasks(newExecutionContext(), []sqlplugin.TimerTasksRow{task})
94
>
s.NoError(err)
95
>
rowsAffected, err := result.RowsAffected()
96
>
s.NoError(err)
97
>
s.Equal(1, int(rowsAffected))
98
>
99
>
task = s.newRandomTimerTaskRow(shardID, timestamp, taskID)
100
>
_, err = s.store.InsertIntoTimerTasks(newExecutionContext(), []sqlplugin.TimerTasksRow{task})
101
>
s.Error(err) // TODO persistence layer should do proper error translation
102
>
}
103
104
func (s *historyHistoryTimerTaskSuite) TestInsert_Multiple_Fail_Duplicate() {