diff --git a/pkg/backend/redis/redis_test.go b/pkg/backend/redis/redis_test.go index d097d55..d46f6c2 100644 --- a/pkg/backend/redis/redis_test.go +++ b/pkg/backend/redis/redis_test.go @@ -278,6 +278,27 @@ var _ = Describe("Backend", func() { Expect(err).To(Equal(iface.TaskQueueNotFound)) }) }) + When("the large queue exists", func() { + It("can delete the queue", func() { + queue := testutil.MustCreateQueue(backend, SampleQueueSpec) + // numOfTasks % chunkSizeInGet != 0 + // numOfTasks % chunkSizeInDelete != 0 + numOfTasks := 1234567 + for i := 0; i