ctx context.Context,
request *DeleteTasksRequest,
resp, err := m.queue.RangeDeleteMessages(ctx, &InternalRangeDeleteMessagesRequest{
QueueType: request.QueueKey.QueueType,
QueueName: request.QueueKey.GetQueueName(),
InclusiveMaxMessageMetadata: request.InclusiveMaxMessageMetadata,
})
if err != nil {
return nil, err
}