159
ctx context.Context,
160
request *persistence.CompleteTasksLessThanRequest,
162
>
if request.ExclusiveMaxPass != 0 {
163
return 0, serviceerror.NewInternal("invalid CompleteTasksLessThan request on queue")
164
}
165
166
>
nidBytes, err := primitives.ParseUUID(request.NamespaceID)
task_v1.go
167
>
if err != nil {
168
return 0, serviceerror.NewUnavailable(err.Error())
169
}
170
>
tqId, tqHash := taskQueueIdAndHash(nidBytes, request.TaskQueueName, request.TaskType, request.Subqueue)
task_v1.go
171
>
result, err := m.DB.DeleteFromTasks(ctx, sqlplugin.TasksFilter{
172
>
RangeHash: tqHash,
173
>
TaskQueueID: tqId,
174
>
ExclusiveMaxTaskID: &request.ExclusiveMaxTaskID,
175
>
Limit: &request.Limit,
176
>
})
177
>
if err != nil {
178
return 0, serviceerror.NewUnavailable(err.Error())
179
}
180
>
nRows, err := result.RowsAffected()
task_v1.go
181
>
if err != nil {
182
return 0, serviceerror.NewUnavailablef("rowsAffected returned error: %v", err)
183
}
185
}
186