739
limit int,
740
subqueue subqueueIndex,
741
>
) (int, error) {
db.go
742
>
n, err := db.store.CompleteTasksLessThan(ctx, &persistence.CompleteTasksLessThanRequest{
743
>
NamespaceID: db.queue.NamespaceId(),
744
>
TaskQueueName: db.queue.PersistenceName(),
745
>
TaskType: db.queue.TaskType(),
746
>
ExclusiveMaxTaskID: exclusiveMaxTaskID,
747
>
Subqueue: int(subqueue),
748
>
Limit: limit,
749
>
})
750
>
if err != nil {
751
db.logger.Error("Persistent store operation failure",
752
tag.StoreOperationCompleteTasksLessThan,