28
}
29
30
>
response, err := historyTaskQueueManager.ReadRawTasks(ctx, &persistence.ReadTasksRequest{
api.go
31
>
QueueKey: persistence.QueueKey{
32
>
QueueType: persistence.QueueTypeHistoryDLQ,
33
>
Category: category,
34
>
SourceCluster: req.DlqKey.SourceCluster,
35
>
TargetCluster: req.DlqKey.TargetCluster,
36
>
},
37
>
PageSize: int(req.PageSize),
38
>
NextPageToken: req.NextPageToken,
39
>
})
40
>
if err != nil {
41
if errors.Is(err, persistence.ErrReadTasksNonPositivePageSize) {
42
return nil, consts.ErrInvalidPageSize