From 13578101916ce1e867dddfc86776e9cb10534947 Mon Sep 17 00:00:00 2001 From: Joe Fleming Date: Wed, 4 May 2016 12:41:37 -0700 Subject: [PATCH] ease up on the debugging output --- src/worker.js | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/src/worker.js b/src/worker.js index fa98c68..cbc9570 100644 --- a/src/worker.js +++ b/src/worker.js @@ -35,7 +35,6 @@ export default class Job extends events.EventEmitter { } _claimJob(job) { - this.debug(`Attempting to claim job ${job._id}`); const m = moment(); const startTime = m.toISOString(); const expirationTime = m.add(job._source.timeout).toISOString(); @@ -204,8 +203,12 @@ export default class Job extends events.EventEmitter { }) .then((mappedJobs) => mappedJobs.filter(Boolean)) .then((claimedJobs) => { - if (claimedJobs.length !== 1) return; + if (claimedJobs.length !== 1) { + this.debug(`All ${jobs.length} jobs already claimed`); + return; + } const job = claimedJobs[0]; + this.debug(`Claimed job ${job._id}`); return this._performJob(job); }) .finally(() => this._startJobPolling());