Add unique id for each worker and pass it to the child process.env.JE…

…ST_WORKER_ID

packages/jest-worker/src/__tests__/index.test.js

@@ -122,10 +122,26 @@ it('tries instantiating workers with the right options', () => {
   expect(Worker.mock.calls[0][0]).toEqual({
     forkOptions: {execArgv: []},
     maxRetries: 6,
+    workerId: 1,
     workerPath: '/tmp/baz.js',
   });
 });
 
+it('create multiple workers with unique worker ids', () => {
+  // eslint-disable-next-line no-new
+  new Farm('/tmp/baz.js', {
+    exposedMethods: ['foo', 'bar'],
+    forkOptions: {execArgv: []},
+    maxRetries: 6,
+    numWorkers: 3,
+  });
+
+  expect(Worker).toHaveBeenCalledTimes(3);
+  expect(Worker.mock.calls[0][0].workerId).toEqual(1);
+  expect(Worker.mock.calls[1][0].workerId).toEqual(2);
+  expect(Worker.mock.calls[2][0].workerId).toEqual(3);
+});
+
 it('makes a non-existing relative worker throw', () => {
   expect(
     () =>

packages/jest-worker/src/__tests__/worker.test.js

@@ -57,6 +57,7 @@ it('passes fork options down to child_process.fork, adding the defaults', () =>
       execPath: 'hello',
     },
     maxRetries: 3,
+    workerId: process.env.JEST_WORKER_ID,
     workerPath: '/tmp/foo/bar/baz.js',
   });
 
@@ -70,6 +71,17 @@ it('passes fork options down to child_process.fork, adding the defaults', () =>
   });
 });
 
+it('passes workerId to the child process and assign it to env.JEST_WORKER_ID', () => {
+  new Worker({
+    forkOptions: {},
+    maxRetries: 3,
+    workerId: 2,
+    workerPath: '/tmp/foo',
+  });
+
+  expect(childProcess.fork.mock.calls[0][1].env.JEST_WORKER_ID).toEqual(2);
+});
+
 it('initializes the child process with the given workerPath', () => {
   new Worker({
     forkOptions: {},

packages/jest-worker/src/index.js

@@ -67,13 +67,16 @@ export default class {
     }
 
     // Build the options once for all workers to avoid allocating extra objects.
-    const workerOptions = {
+    const sharedWorkerOptions = {
       forkOptions: options.forkOptions || {},
       maxRetries: options.maxRetries || 3,
       workerPath,
     };
 
     for (let i = 0; i < numWorkers; i++) {
+      const workerOptions = Object.assign({}, sharedWorkerOptions, {
+        workerId: i + 1,
+      });
       const worker = new Worker(workerOptions);
       const workerStdout = worker.getStdout();
       const workerStderr = worker.getStderr();

packages/jest-worker/src/types.js

@@ -47,6 +47,7 @@ export type WorkerOptions = {|
   forkOptions: ForkOptions,
   maxRetries: number,
   workerPath: string,
+  workerId: number,
 |};
 
 // Messages passed from the parent to the children.

packages/jest-worker/src/worker.js

@@ -79,7 +79,9 @@ export default class {
       Object.assign(
         {
           cwd: process.cwd(),
-          env: process.env,
+          env: Object.assign({}, process.env, {
+            JEST_WORKER_ID: this._options.workerId,
+          }),
           // suppress --debug / --inspect flags while preserving others (like --harmony)
           execArgv: process.execArgv.filter(v => !/^--(debug|inspect)/.test(v)),
           silent: true,