57
})
58
t.Run("QueueDoesNotExist", func(t *testing.T) {
60
>
61
>
queueKey := persistencetest.GetQueueKey(t, persistencetest.WithQueueType(persistence.QueueTypeHistoryDLQ))
62
>
_, err := deletedlqtasks.Invoke(ctx, manager, &historyservice.DeleteDLQTasksRequest{
63
>
DlqKey: &commonspb.HistoryDLQKey{
64
>
TaskCategory: int32(queueKey.Category.ID()),
65
>
SourceCluster: queueKey.SourceCluster,
66
>
TargetCluster: queueKey.TargetCluster,
67
>
},
68
>
InclusiveMaxTaskMetadata: &commonspb.HistoryDLQTaskMetadata{
69
>
MessageId: persistence.FirstQueueMessageID,
70
>
},
71
>
}, tasks.NewDefaultTaskCategoryRegistry())
72
>
require.Error(t, err)
73
>
assert.Equal(t, codes.NotFound, serviceerror.ToStatus(err).Code(), err.Error())
74
>
})
75
}