diff --git a/packages/cli-node/src/parallel/index.ts b/packages/cli-node/src/parallel/index.ts index 7aadbafe70..f8f9d4d51f 100644 --- a/packages/cli-node/src/parallel/index.ts +++ b/packages/cli-node/src/parallel/index.ts @@ -14,5 +14,8 @@ * limitations under the License. */ -export type { ConcurrentTasksOptions, WorkerQueueThreadsOptions } from './parallel'; +export type { + ConcurrentTasksOptions, + WorkerQueueThreadsOptions, +} from './parallel'; export { runConcurrentTasks, runWorkerQueueThreads } from './parallel'; diff --git a/packages/cli-node/src/parallel/parallel.ts b/packages/cli-node/src/parallel/parallel.ts index f925ed91e4..9d36852351 100644 --- a/packages/cli-node/src/parallel/parallel.ts +++ b/packages/cli-node/src/parallel/parallel.ts @@ -65,9 +65,7 @@ function getEnvironmentConcurrency() { `The ${DEPRECATED_CONCURRENCY_ENV_VAR} environment variable is deprecated, use ${CONCURRENCY_ENV_VAR} instead`, ); } - return parseConcurrencyOption( - process.env[DEPRECATED_CONCURRENCY_ENV_VAR], - ); + return parseConcurrencyOption(process.env[DEPRECATED_CONCURRENCY_ENV_VAR]); } return defaultConcurrency; } @@ -105,10 +103,7 @@ export async function runConcurrentTasks( [Symbol.iterator]: () => sharedIterator, }; - const workerCount = Math.max( - Math.floor(concurrencyFactor * concurrency), - 1, - ); + const workerCount = Math.max(Math.floor(concurrencyFactor * concurrency), 1); await Promise.all( Array(workerCount) .fill(0)