- Add more tests

Signed-off-by: Valery Piashchynski <[email protected]>

1 files changed, 5 insertions, 7 deletions

diff --git a/pkg/worker_watcher/container/vec.go b/pkg/worker_watcher/container/vec.go
index 8072af10..b9150c43 100644
--- a/pkg/worker_watcher/container/vec.go
+++ b/pkg/worker_watcher/container/vec.go
@@ -38,13 +38,11 @@ func (v *Vec) Dequeue(ctx context.Context) (worker.BaseProcess, error) {
 		return nil, errors.E(errors.WatcherStopped)
 	}
 
-	for {
-		select {
-		case w := <-v.workers:
-			return w, nil
-		case <-ctx.Done():
-			return nil, errors.E(ctx.Err(), errors.NoFreeWorkers)
-		}
+	select {
+	case w := <-v.workers:
+		return w, nil
+	case <-ctx.Done():
+		return nil, errors.E(ctx.Err(), errors.NoFreeWorkers)
 	}
 }