41
factory ExecutableFactory,
42
taskPostProcessor taskPostProcessorFn,
44
>
paginationFnProvider := func(r Range) collection.PaginationFn[tasks.Task] {
45
>
return func(paginationToken []byte) ([]tasks.Task, []byte, error) {
46
>
ctx, cancel := newQueueIOContext()
47
>
defer cancel()
48
>
49
>
request := &persistence.GetHistoryTasksRequest{
50
>
ShardID: shard.GetShardID(),
51
>
TaskCategory: category,
52
>
InclusiveMinTaskKey: r.InclusiveMin,
53
>
ExclusiveMaxTaskKey: r.ExclusiveMax,
54
>
BatchSize: options.BatchSize(),
55
>
NextPageToken: paginationToken,
56
>
}
57
>
58
>
resp, err := shard.GetHistoryTasks(ctx, request)
59
>
if err != nil {
60
return nil, nil, err
61
}