diff --git a/packages/cli/src/lib/parallel.ts b/packages/cli/src/lib/parallel.ts index ec3d5493c0..d51e9b3b2d 100644 --- a/packages/cli/src/lib/parallel.ts +++ b/packages/cli/src/lib/parallel.ts @@ -153,13 +153,14 @@ export type WorkerQueueThreadsOptions = { export async function runWorkerQueueThreads( options: WorkerQueueThreadsOptions, ): Promise { + const items = Array.from(options.items); const { workerFactory, workerData, - threadCount = os.cpus().length / 2, + threadCount = Math.min(getEnvironmentParallelism(), items.length), } = options; - const iterator = options.items[Symbol.iterator](); + const iterator = items[Symbol.iterator](); const results = new Array(); let itemIndex = 0;