add maxWorkers to globalConfig

integration_tests/__tests__/__snapshots__/custom_reporters.test.js.snap

@@ -32,7 +32,6 @@ Object {
     "christoph": "pojer",
     "dmitrii": "abramov",
     "hello": "world",
-    "maxWorkers": "<<REPLACED>>",
     "pattern": Object {
       "input": "add_fail.test.js",
       "paths": Array [
@@ -70,7 +69,6 @@ Object {
     "christoph": "pojer",
     "dmitrii": "abramov",
     "hello": "world",
-    "maxWorkers": "<<REPLACED>>",
     "pattern": Object {
       "input": "add.test.js",
       "paths": Array [
@@ -122,7 +120,6 @@ Object {
     "path": false,
   },
   "options": Object {
-    "maxWorkers": "<<REPLACED>>",
     "pattern": Object {
       "input": "add.test.js",
       "paths": Array [

integration_tests/__tests__/__snapshots__/show_config.test.js.snap

@@ -71,6 +71,7 @@ exports[`jest --showConfig outputs config info and exits 1`] = `
     ],
     "expand": false,
     "mapCoverage": false,
+    "maxWorkers": "[maxWorkers]",
     "noStackTrace": false,
     "notify": false,
     "rootDir": "/mocked/root/path/jest/integration_tests/verbose_reporter",

integration_tests/__tests__/show_config.test.js

@@ -25,6 +25,7 @@ describe('jest --showConfig', () => {
           .replace(/"cacheDirectory": "(.+)"/g, '"cacheDirectory": "/tmp/jest"')
           .replace(/"name": "(.+)"/g, '"name": "[md5 hash]"')
           .replace(/"version": "(.+)"/g, '"version": "[version]"')
+          .replace(/"maxWorkers": (\d+)/g, '"maxWorkers": "[maxWorkers]"')
           .replace(new RegExp(root, 'g'), '/mocked/root/path'),
       test: val => typeof val === 'string',
     });

integration_tests/__tests__/snapshot.test.js

@@ -14,6 +14,9 @@ const path = require('path');
 const {extractSummary} = require('../utils');
 const runJest = require('../runJest');
 
+const skipOnWindows = require('skipOnWindows');
+skipOnWindows.suite();
+
 const emptyTest = 'describe("", () => {it("", () => {})})';
 const snapshotDir = path.resolve(
   __dirname,

packages/jest-cli/src/__tests__/test_runner.test.js

@@ -41,14 +41,14 @@ test('.addReporter() .removeReporter()', () => {
 
 describe('_createInBandTestRun()', () => {
   test('injects the rawModuleMap to each the worker in watch mode', () => {
-    const globalConfig = {watch: true};
+    const globalConfig = {maxWorkers: 2, watch: true};
     const config = {rootDir: '/path/'};
     const rawModuleMap = jest.fn();
     const context = {
       config,
       moduleMap: {getRawModuleMap: () => rawModuleMap},
     };
-    const runner = new TestRunner(globalConfig, {maxWorkers: 2});
+    const runner = new TestRunner(globalConfig, {});
 
     return runner
       ._createParallelTestRun(
@@ -72,10 +72,10 @@ describe('_createInBandTestRun()', () => {
   });
 
   test('does not inject the rawModuleMap in non watch mode', () => {
-    const globalConfig = {watch: false};
+    const globalConfig = {maxWorkers: 1, watch: false};
     const config = {rootDir: '/path/'};
     const context = {config};
-    const runner = new TestRunner(globalConfig, {maxWorkers: 1});
+    const runner = new TestRunner(globalConfig, {});
 
     return runner
       ._createParallelTestRun(

packages/jest-cli/src/cli/index.js

@@ -25,7 +25,6 @@ import chalk from 'chalk';
 import createContext from '../lib/create_context';
 import getChangedFilesPromise from '../get_changed_files_promise';
 import getJest from './get_jest';
-import getMaxWorkers from '../lib/get_max_workers';
 import handleDeprecationWarnings from '../lib/handle_deprecation_warnings';
 import logDebugMessages from '../lib/log_debug_messages';
 import preRunMessage from '../pre_run_message';
@@ -231,7 +230,7 @@ const _buildContextsAndHasteMaps = async (
       createDirectory(config.cacheDirectory);
       const hasteMapInstance = Runtime.createHasteMap(config, {
         console: new Console(outputStream, outputStream),
-        maxWorkers: getMaxWorkers(argv),
+        maxWorkers: globalConfig.maxWorkers,
         resetCache: !config.cache,
         watch: globalConfig.watch,
         watchman: globalConfig.watchman,

packages/jest-cli/src/run_jest.js

@@ -20,7 +20,6 @@ import path from 'path';
 import {Console, formatTestResults} from 'jest-util';
 import chalk from 'chalk';
 import fs from 'graceful-fs';
-import getMaxWorkers from './lib/get_max_workers';
 import getTestSelectionConfig from './lib/get_test_selection_config';
 import SearchSource from './search_source';
 import updateArgv from './lib/update_argv';
@@ -178,7 +177,6 @@ const runJest = async (
     testSelectionConfig: TestSelectionConfig,
   ) => void,
 ) => {
-  const maxWorkers = getMaxWorkers(argv);
   const testSelectionConfig = getTestSelectionConfig(argv);
   const sequencer = new TestSequencer();
   let allTests = [];
@@ -231,7 +229,6 @@ const runJest = async (
   setConfig(contexts, {rootDir: process.cwd()});
 
   const results = await new TestRunner(globalConfig, {
-    maxWorkers,
     pattern: testSelectionConfig,
     startRun,
     testNamePattern: argv.testNamePattern,

packages/jest-cli/src/test_runner.js

@@ -47,7 +47,6 @@ class CancelRun extends Error {
 }
 
 export type TestRunnerOptions = {|
-  maxWorkers: number,
   pattern: TestSelectionConfig,
   startRun: () => *,
   testNamePattern: string,
@@ -91,14 +90,14 @@ class TestRunner {
 
     const aggregatedResults = createAggregatedResults(tests.length);
     const estimatedTime = Math.ceil(
-      getEstimatedTime(timings, this._options.maxWorkers) / 1000,
+      getEstimatedTime(timings, this._globalConfig.maxWorkers) / 1000,
     );
 
     // Run in band if we only have one test or one worker available.
     // If we are confident from previous runs that the tests will finish quickly
     // we also run in band to reduce the overhead of spawning workers.
     const runInBand =
-      this._options.maxWorkers <= 1 ||
+      this._globalConfig.maxWorkers <= 1 ||
       tests.length <= 1 ||
       (tests.length <= 20 &&
         timings.length > 0 &&
@@ -229,12 +228,12 @@ class TestRunner {
       {
         autoStart: true,
         maxConcurrentCallsPerWorker: 1,
-        maxConcurrentWorkers: this._options.maxWorkers,
+        maxConcurrentWorkers: this._globalConfig.maxWorkers,
         maxRetries: 2, // Allow for a couple of transient errors.
       },
       TEST_WORKER_PATH,
     );
-    const mutex = throat(this._options.maxWorkers);
+    const mutex = throat(this._globalConfig.maxWorkers);
     const worker = pify(farm);
 
     // Send test suites to workers continuously instead of all at once to track
@@ -309,7 +308,7 @@ class TestRunner {
     if (collectCoverage) {
       this.addReporter(
         new CoverageReporter(this._globalConfig, {
-          maxWorkers: this._options.maxWorkers,
+          maxWorkers: this._globalConfig.maxWorkers,
         }),
       );
     }

packages/jest-config/src/index.js

@@ -69,6 +69,7 @@ const getConfigs = (
       forceExit: options.forceExit,
       logHeapUsage: options.logHeapUsage,
       mapCoverage: options.mapCoverage,
+      maxWorkers: options.maxWorkers,
       noStackTrace: options.noStackTrace,
       notify: options.notify,
       projects: options.projects,

packages/jest-config/src/normalize.js

@@ -15,6 +15,7 @@ import crypto from 'crypto';
 import path from 'path';
 import {ValidationError, validate} from 'jest-validate';
 import chalk from 'chalk';
+import getMaxWorkers from './get_max_workers';
 import glob from 'glob';
 import Resolver from 'jest-resolve';
 import utils from 'jest-regex-util';
@@ -452,6 +453,8 @@ function normalize(options: InitialOptions, argv: Argv) {
       ? 'none'
       : argv.updateSnapshot ? 'all' : 'new';
 
+  newOptions.maxWorkers = getMaxWorkers(argv);
+
   if (babelJest) {
     const regeneratorRuntimePath = Resolver.findNodeModule(
       'regenerator-runtime/runtime',

types/Config.js

@@ -137,6 +137,7 @@ export type GlobalConfig = {|
   forceExit: boolean,
   logHeapUsage: boolean,
   mapCoverage: boolean,
+  maxWorkers: number,
   noStackTrace: boolean,
   notify: boolean,
   projects: Array<Glob>,