Comparing version 0.2.1 to 0.2.2
@@ -81,2 +81,3 @@ 'use strict'; | ||
timeout: _this.timeout, | ||
process_expiration: new Date(0), // use epoch so the job query works | ||
created_at: new Date(), | ||
@@ -83,0 +84,0 @@ attempts: 0, |
@@ -72,2 +72,3 @@ 'use strict'; | ||
_this._checker = false; | ||
_this.debug('Created worker for type ' + _this.type); | ||
_this._startJobPolling(); | ||
@@ -175,2 +176,3 @@ return _this; | ||
setTimeout(function () { | ||
_this2.debug('Timeout processing job ' + job._id); | ||
reject(new _errors.WorkerTimeoutError({ | ||
@@ -204,3 +206,4 @@ timeout: job._source.timeout, | ||
if (err.statusCode === 409) return false; | ||
throw err; | ||
_this2.debug('Failure saving job output ' + job._id, err); | ||
_this2.emit('job_error', err); | ||
}); | ||
@@ -215,3 +218,3 @@ }, function (jobErr) { | ||
_this2.debug('Failure occurred on job ' + job._id); | ||
_this2.debug('Failure occurred on job ' + job._id, jobErr); | ||
_this2.emit('job_error', jobErr); | ||
@@ -218,0 +221,0 @@ return _this2._failJob(job, jobErr.toString()); |
{ | ||
"name": "esqueue", | ||
"version": "0.2.1", | ||
"description": "", | ||
"version": "0.2.2", | ||
"description": "Job queue, powered by Elasticsearch", | ||
"main": "lib/index.js", | ||
@@ -14,2 +14,8 @@ "scripts": { | ||
"author": "Joe Fleming (https://github.com/w33ble)", | ||
"keywords": [ | ||
"job", | ||
"queue", | ||
"worker", | ||
"elasticsearch" | ||
], | ||
"repository": { | ||
@@ -16,0 +22,0 @@ "type": "git", |
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
31740
622