batch-cluster
Advanced tools
Comparing version 5.9.0 to 5.9.1
@@ -20,2 +20,7 @@ # Changelog | ||
## v5.9.1 | ||
- 🐞 Errors after a process has shut down are logged and not propagated | ||
- 📦 Updated deps | ||
## v5.9.0 | ||
@@ -22,0 +27,0 @@ |
@@ -362,3 +362,10 @@ "use strict"; | ||
BatchProcess.prototype.onError = function (source, _error, task) { | ||
if ((String_1.toS(_error) + String_1.toS(_error.message)).includes("Cannot call write after a stream was destroyed")) { | ||
if (this._endPromise != null) { | ||
// We're ending already, so don't propogate the error. | ||
// This is expected due to race conditions stdin EPIPE and process shutdown. | ||
BatchCluster_1.logger().debug(this.name + ".onError() post-end (expected and not propagated)", { | ||
source: source, | ||
_error: _error, | ||
task: task | ||
}); | ||
return; | ||
@@ -365,0 +372,0 @@ } |
@@ -129,3 +129,3 @@ "use strict"; | ||
error_1 = _a.sent(); | ||
this.reject(error_1, "Task.onData(): rejected"); | ||
this.reject(error_1, "Task.resolve() was rejected"); | ||
return [3 /*break*/, 3]; | ||
@@ -132,0 +132,0 @@ case 3: return [2 /*return*/]; |
{ | ||
"name": "batch-cluster", | ||
"version": "5.9.0", | ||
"version": "5.9.1", | ||
"description": "Manage a cluster of child processes", | ||
@@ -36,7 +36,7 @@ "main": "dist/BatchCluster.js", | ||
"devDependencies": { | ||
"@types/chai": "^4.2.5", | ||
"@types/chai": "^4.2.6", | ||
"@types/chai-as-promised": "^7.1.2", | ||
"@types/chai-string": "^1.4.2", | ||
"@types/mocha": "^5.2.7", | ||
"@types/node": "^12.12.11", | ||
"@types/node": "^12.12.14", | ||
"chai": "^4.2.0", | ||
@@ -55,6 +55,6 @@ "chai-as-promised": "^7.1.1", | ||
"tslint": "^5.20.1", | ||
"typedoc": "^0.15.2", | ||
"typescript": "^3.7.2", | ||
"typedoc": "^0.15.3", | ||
"typescript": "^3.7.3", | ||
"wtfnode": "^0.8.0" | ||
} | ||
} |
131928
2712