w33ble/elastiq
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

ease up on the debugging output

Browse Source
This commit is contained in:
Joe Fleming
2016-05-04 12:41:37 -07:00
parent 48f34a8bc8
commit 1357810191
1 changed files with 5 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
src/worker.js
View File

@@ -35,7 +35,6 @@ export default class Job extends events.EventEmitter {
} }
_claimJob(job) { _claimJob(job) {
this.debug(`Attempting to claim job ${job._id}`);
const m = moment(); const m = moment();
const startTime = m.toISOString(); const startTime = m.toISOString();
const expirationTime = m.add(job._source.timeout).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((mappedJobs) => mappedJobs.filter(Boolean))
.then((claimedJobs) => { .then((claimedJobs) => {
if (claimedJobs.length !== 1) return; if (claimedJobs.length !== 1) {
this.debug(`All ${jobs.length} jobs already claimed`);
return;
}
const job = claimedJobs[0]; const job = claimedJobs[0];
this.debug(`Claimed job ${job._id}`);
return this._performJob(job); return this._performJob(job);
}) })
.finally(() => this._startJobPolling()); .finally(() => this._startJobPolling());