From 38532a6296478c210269495688e85f75e45f6796 Mon Sep 17 00:00:00 2001 From: Joe Fleming Date: Tue, 10 May 2016 17:28:27 -0700 Subject: [PATCH] fix scoping issue, add debugging on worker register --- src/worker.js | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/src/worker.js b/src/worker.js index f2af1d7..d90587a 100644 --- a/src/worker.js +++ b/src/worker.js @@ -26,6 +26,7 @@ export default class Job extends events.EventEmitter { this.debug = (...msg) => debug(...msg, `id: ${this.id}`); this._checker = false; + this.debug(`Created worker for type ${this.type}`); this._startJobPolling(); } @@ -118,7 +119,7 @@ export default class Job extends events.EventEmitter { const workerOutput = new Promise((resolve, reject) => { resolve(this.workerFn.call(null, job._source.payload)); - setTimeout(function () { + setTimeout(() => { this.debug(`Timeout processing job ${job._id}`); reject(new WorkerTimeoutError({ timeout: job._source.timeout,