79
ctx context.Context,
80
filter sqlplugin.TasksFilterV2,
82
>
if filter.ExclusiveMaxLevel == nil {
83
return nil, serviceerror.NewInternal("missing ExclusiveMaxTaskLevel")
84
}
85
>
if filter.Limit == nil || *filter.Limit == 0 {
task_v2.go
86
return nil, serviceerror.NewInternal("missing limit parameter")
87
}
89
>
rangeDeleteTaskV2Qry,
90
>
filter.RangeHash,
91
>
filter.TaskQueueID,
92
>
filter.RangeHash,
93
>
filter.TaskQueueID,
94
>
filter.ExclusiveMaxLevel.TaskPass,
95
>
filter.ExclusiveMaxLevel.TaskID,
96
>
*filter.Limit,
97
>
)
98
}