44
ctx context.Context,
45
filter sqlplugin.TasksFilterV2,
46
>
) ([]sqlplugin.TasksRowV2, error) {
task_v2.go
47
>
if filter.InclusiveMinLevel == nil {
48
return nil, serviceerror.NewInternal("missing InclusiveMinLevel")
49
}
51
>
var rows []sqlplugin.TasksRowV2
52
>
switch {
53
>
case filter.PageSize != nil:
54
>
err = mdb.conn.SelectContext(ctx,
55
>
&rows, getTaskV2QryWithLimit,
56
>
filter.RangeHash,
57
>
filter.TaskQueueID,
58
>
filter.InclusiveMinLevel.TaskPass,
59
>
filter.InclusiveMinLevel.TaskID,
60
>
*filter.PageSize,
61
>
)
62
default:
63
err = mdb.conn.SelectContext(ctx,