add debugging on job timeout

2016-05-10 16:57:40 -07:00
parent 82506a74e8
commit e077442340
1 changed files with 1 additions and 0 deletions
--- a/src/worker.js
+++ b/src/worker.js
@@ -119,6 +119,7 @@ export default class Job extends events.EventEmitter {
      resolve(this.workerFn.call(null, job._source.payload));

      setTimeout(function () {
+        this.debug(`Timeout processing job ${job._id}`);
        reject(new WorkerTimeoutError({
          timeout: job._source.timeout,
          jobId: job._id,