699
exclusiveMaxTaskID int64,
700
batchSize int,
701
>
) (*persistence.GetTasksResponse, error) {
db.go
702
>
return db.store.GetTasks(ctx, &persistence.GetTasksRequest{
703
>
NamespaceID: db.queue.NamespaceId(),
704
>
TaskQueue: db.queue.PersistenceName(),
705
>
TaskType: db.queue.TaskType(),
706
>
InclusiveMinTaskID: inclusiveMinTaskID,
707
>
ExclusiveMaxTaskID: exclusiveMaxTaskID,
708
>
Subqueue: int(subqueue),
709
>
PageSize: batchSize,
710
>
})
711
>
}
712
713
// GetFairTasks returns a batch of tasks after the given level