201
ctx context.Context,
202
request *p.CompleteTasksLessThanRequest,
204
>
if request.ExclusiveMaxPass != 0 {
205
return 0, serviceerror.NewInternal("invalid CompleteTasksLessThan request on queue")
206
}
207
209
>
templateCompleteTasksLessThanQuery,
210
>
request.NamespaceID,
211
>
request.TaskQueueName,
212
>
request.TaskType,
213
>
rowTypeTaskInSubqueue(request.Subqueue),
214
>
request.ExclusiveMaxTaskID,
215
>
).WithContext(ctx)
216
>
err := query.Exec()
217
>
if err != nil {
218
return 0, gocql.ConvertError("CompleteTasksLessThan", err)
219
}
221
}
222