345
}
346
348
>
numTasks := 20
349
>
replicationTasks := s.AddRandomTasks(
350
>
tasks.CategoryReplication,
351
>
numTasks,
352
>
func(workflowKey definition.WorkflowKey, taskID int64, visibilityTimestamp time.Time) tasks.Task {
353
>
return &tasks.HistoryReplicationTask{
354
>
WorkflowKey: workflowKey,
355
>
TaskID: taskID,
356
>
VisibilityTimestamp: visibilityTimestamp,
357
>
}
358
>
},
359
)
360
362
>
loadedTasks := s.PaginateTasks(
363
>
tasks.CategoryReplication,
364
>
inclusiveMinTaskKey,
365
>
exclusiveMaxTaskKey,
366
>
rand.Intn(len(replicationTasks)*2)+1,
367
>
)
368
>
s.Equal(replicationTasks, loadedTasks)
369
}
370