267
}
268
270
>
numTasks := 20
271
>
transferTasks := s.AddRandomTasks(
272
>
tasks.CategoryTransfer,
273
>
numTasks,
274
>
func(workflowKey definition.WorkflowKey, taskID int64, visibilityTimestamp time.Time) tasks.Task {
275
>
return &tasks.ActivityTask{
276
>
WorkflowKey: workflowKey,
277
>
TaskID: taskID,
278
>
VisibilityTimestamp: visibilityTimestamp,
279
>
}
280
>
},
281
)
282
284
>
loadedTasks := s.PaginateTasks(
285
>
tasks.CategoryTransfer,
286
>
inclusiveMinTaskKey,
287
>
exclusiveMaxTaskKey,
288
>
rand.Intn(len(transferTasks)*2)+1,
289
>
)
290
>
s.Equal(transferTasks, loadedTasks)
291
}
292