69
}
70
72
>
shardID := rand.Int31()
73
>
timestamp := s.now()
74
>
taskID := int64(1)
75
>
76
>
task1 := s.newRandomTimerTaskRow(shardID, timestamp, taskID)
77
>
timestamp = timestamp.Add(time.Millisecond)
78
>
taskID++
79
>
task2 := s.newRandomTimerTaskRow(shardID, timestamp, taskID)
80
>
result, err := s.store.InsertIntoTimerTasks(newExecutionContext(), []sqlplugin.TimerTasksRow{task1, task2})
81
>
s.NoError(err)
82
>
rowsAffected, err := result.RowsAffected()
83
>
s.NoError(err)
84
>
s.Equal(2, int(rowsAffected))
85
>
}
86
87
func (s *historyHistoryTimerTaskSuite) TestInsert_Single_Fail_Duplicate() {