Apply suggestions from code review

Co-authored-by: Shingo Omura <[email protected]>

Author: shioshiota

pkg/backend/config/config.go

@@ -54,7 +54,7 @@ type RedisClientConfig struct {
 	IdleCheckFrequency time.Duration `json:"idleCheckFrequency" yaml:"idleCheckFrequency" default:"1m"`
 
 	ChunkSizeInGet    int `json:"chunkSizeInGet" yaml:"chunkSizeInGet" default:"10000"`
-	ChunkSizeInDelete int `json:"chunkSizeInDelete" yaml:"chunkSizeInGet" default:"1000"`
+	ChunkSizeInDelete int `json:"chunkSizeInDelete" yaml:"chunkSizeInDelete" default:"1000"`
 }
 
 func (c RedisClientConfig) NewClient() *redis.Client {

pkg/backend/redis/queue.go

@@ -218,7 +218,7 @@ func (b *Backend) DeleteQueue(ctx context.Context, queueName string) error {
 	// .. task_keys = collect task keys
 	// WATCh task_keys
 	// MULTI
-	// UNLINK {queue_key} worker_keys task_keys
+	// UNLINK {queue_key} worker_keys task_keys (chunked)
 	// HDEL {all_queues_key} {queueName}
 	// EXEC
 	txf := func(tx *redis.Tx) error {
@@ -240,7 +240,7 @@ func (b *Backend) DeleteQueue(ctx context.Context, queueName string) error {
 		tx.Watch(taskKeysToDelete...)
 		keysToDelete = append(keysToDelete, taskKeysToDelete...)
 
-		chunkSize := b.ChunkSizeInGet
+		chunkSize := b.ChunkSizeInDelete
 		numOfKeysToDelete := len(keysToDelete)
 		_, err = tx.TxPipelined(func(pipe redis.Pipeliner) error {
 			for begin := 0; begin < numOfKeysToDelete; begin += chunkSize {