jest-worker - npm Package Compare versions

Comparing version 29.5.0 to 29.6.0

build/base/BaseWorkerPool.js

@@ -37,4 +37,6 @@ 'use strict';
   _workers;
+  _workerPath;
   constructor(workerPath, options) {
     this._options = options;
+    this._workerPath = workerPath;
     this._workers = new Array(options.numWorkers);
@@ -80,2 +82,19 @@ const stdout = (0, _mergeStream().default)();
   }
+  restartWorkerIfShutDown(workerId) {
+    if (this._workers[workerId].state === _types.WorkerStates.SHUT_DOWN) {
+      const {forkOptions, maxRetries, resourceLimits, setupArgs} =
+        this._options;
+      const workerOptions = {
+        forkOptions,
+        idleMemoryLimit: this._options.idleMemoryLimit,
+        maxRetries,
+        resourceLimits,
+        setupArgs,
+        workerId,
+        workerPath: this._workerPath
+      };
+      const worker = this.createWorker(workerOptions);
+      this._workers[workerId] = worker;
+    }
+  }
   createWorker(_workerOptions) {
@@ -82,0 +101,0 @@ throw Error('Missing method createWorker in WorkerPool');

build/types.js

@@ -49,6 +49,12 @@ 'use strict';
 const PARENT_MESSAGE_MEM_USAGE = 4;
+
+// Option objects.
+
+// Messages passed from the parent to the children.
+
+// Messages passed from the children to the parent.
+
+// Queue types.
 exports.PARENT_MESSAGE_MEM_USAGE = PARENT_MESSAGE_MEM_USAGE;
-let WorkerStates;
-exports.WorkerStates = WorkerStates;
-(function (WorkerStates) {
+let WorkerStates = /*#__PURE__*/ (function (WorkerStates) {
   WorkerStates['STARTING'] = 'starting';
@@ -60,7 +66,9 @@ WorkerStates['OK'] = 'ok';
   WorkerStates['SHUT_DOWN'] = 'shut-down';
-})(WorkerStates || (exports.WorkerStates = WorkerStates = {}));
-let WorkerEvents;
+  return WorkerStates;
+})({});
+exports.WorkerStates = WorkerStates;
+let WorkerEvents = /*#__PURE__*/ (function (WorkerEvents) {
+  WorkerEvents['STATE_CHANGE'] = 'state-change';
+  return WorkerEvents;
+})({});
 exports.WorkerEvents = WorkerEvents;
-(function (WorkerEvents) {
-  WorkerEvents['STATE_CHANGE'] = 'state-change';
-})(WorkerEvents || (exports.WorkerEvents = WorkerEvents = {}));

build/WorkerPool.js

@@ -20,2 +20,3 @@ 'use strict';
   send(workerId, request, onStart, onEnd, onCustomMessage) {
+    this.restartWorkerIfShutDown(workerId);
     this.getWorkerById(workerId).send(request, onStart, onEnd, onCustomMessage);
@@ -22,0 +23,0 @@ }

package.json

 {
   "name": "jest-worker",
-  "version": "29.5.0",
+  "version": "29.6.0",
   "repository": {
@@ -21,3 +21,3 @@ "type": "git",
     "@types/node": "*",
-    "jest-util": "^29.5.0",
+    "jest-util": "^29.6.0",
     "merge-stream": "^2.0.0",
@@ -28,8 +28,8 @@ "supports-color": "^8.0.0"
     "@babel/core": "^7.11.6",
-    "@tsd/typescript": "^4.9.0",
+    "@tsd/typescript": "^5.0.4",
     "@types/merge-stream": "^1.1.2",
     "@types/supports-color": "^8.1.0",
     "get-stream": "^6.0.0",
-    "jest-leak-detector": "^29.5.0",
-    "tsd-lite": "^0.6.0",
+    "jest-leak-detector": "^29.6.0",
+    "tsd-lite": "^0.7.0",
     "worker-farm": "^1.6.0"
@@ -43,3 +43,3 @@ },
   },
-  "gitHead": "39f3beda6b396665bebffab94e8d7c45be30454c"
+  "gitHead": "c1e5b8a38ef54bb138409f89831942ebf6a7a67e"
 }

No alert changes

Improved metrics

Total package byte prevSize

90554

increased by0.83%

Lines of code

2415

increased by1%

Dependency changes

• Updatedjest-util@^29.6.0