}
shardID := rand.Int31()
timestamp := s.now()
taskID := int64(1)
task := s.newRandomTimerTaskRow(shardID, timestamp, taskID)
result, err := s.store.InsertIntoTimerTasks(newExecutionContext(), []sqlplugin.TimerTasksRow{task})
s.NoError(err)
rowsAffected, err := result.RowsAffected()
s.NoError(err)
s.Equal(1, int(rowsAffected))
}
func (s *historyHistoryTimerTaskSuite) TestInsert_Multiple_Success() {