262
ctx context.Context,
263
request *p.DeleteTaskQueueRequest,
265
>
query := d.Session.Query(switchTasksTable(templateDeleteTaskQueueQuery, d.version),
266
>
request.TaskQueue.NamespaceID,
267
>
request.TaskQueue.TaskQueueName,
268
>
request.TaskQueue.TaskQueueType,
269
>
rowTypeTaskQueue,
270
>
taskQueueTaskID,
271
>
request.RangeID,
272
>
).WithContext(ctx)
273
>
274
>
previous := make(map[string]any)
275
>
applied, err := query.MapScanCAS(previous)
276
>
if err != nil {
277
return gocql.ConvertError("DeleteTaskQueue", err)
278
}
280
return &p.ConditionFailedError{
281
Msg: fmt.Sprintf("DeleteTaskQueue operation failed: expected_range_id=%v but found %+v", request.RangeID, previous),