Fix delete collection error channel size

Kubernetes-commit: f609a8e0b525ee22b3ea1a850a3b0504627525ea
2021-10-25 08:07:21 +02:00 · 2021-10-25 08:07:21 +02:00 · 0f1abbd5e4
parent c6a8965948
commit 0f1abbd5e4
1 changed files with 1 additions and 1 deletions
--- a/pkg/registry/generic/registry/store.go
+++ b/pkg/registry/generic/registry/store.go
@ -1126,7 +1126,7 @@ func (e *Store) DeleteCollection(ctx context.Context, deleteValidation rest.Vali
 	}
 	wg := sync.WaitGroup{}
 	toProcess := make(chan int, 2*workersNumber)
-	errs := make(chan error, workersNumber)
+	errs := make(chan error, workersNumber+1)
 	workersExited := make(chan struct{})
 	distributorExited := make(chan struct{})