95
}
96
97
>
inclusiveMinTaskID, exclusiveMaxTaskID, err := getImmediateTaskReadRange(request)
execution_tasks.go
98
>
if err != nil {
99
return nil, err
100
}
101
102
>
rows, err := m.DB.RangeSelectFromHistoryImmediateTasks(ctx, sqlplugin.HistoryImmediateTasksRangeFilter{
execution_tasks.go
103
>
ShardID: request.ShardID,
104
>
CategoryID: int32(categoryID),
105
>
InclusiveMinTaskID: inclusiveMinTaskID,
106
>
ExclusiveMaxTaskID: exclusiveMaxTaskID,
107
>
PageSize: request.BatchSize,
108
>
})
109
>
if err != nil {
110
if err != sql.ErrNoRows {
111
return nil, serviceerror.NewUnavailablef(