219
}
220
222
>
pageSize := 100
223
>
224
>
shardID := rand.Int31()
225
>
minTimestamp := s.now()
226
>
maxTimestamp := minTimestamp.Add(time.Minute)
227
>
228
>
filter := sqlplugin.TimerTasksRangeFilter{
229
>
ShardID: shardID,
230
>
InclusiveMinVisibilityTimestamp: minTimestamp,
231
>
ExclusiveMaxVisibilityTimestamp: maxTimestamp,
232
>
PageSize: 0,
233
>
}
234
>
result, err := s.store.RangeDeleteFromTimerTasks(newExecutionContext(), filter)
235
>
s.NoError(err)
236
>
rowsAffected, err := result.RowsAffected()
237
>
s.NoError(err)
238
>
s.Equal(0, int(rowsAffected))
239
>
240
>
filter.PageSize = pageSize
241
>
rows, err := s.store.RangeSelectFromTimerTasks(newExecutionContext(), filter)
242
>
s.NoError(err)
243
>
for index := range rows {
244
rows[index].ShardID = shardID
245
}
247
}
248