Socket
Socket
Sign inDemoInstall

esqueue

Package Overview
Dependencies
Maintainers
1
Versions
32
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

esqueue - npm Package Compare versions

Comparing version 0.2.1 to 0.2.2

1

lib/job.js

@@ -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,

7

lib/worker.js

@@ -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",

SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap
  • Changelog

Packages

npm

Stay in touch

Get open source security insights delivered straight into your inbox.


  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc