missing indices need to return an array
This commit is contained in:
@@ -180,7 +180,7 @@ export default class Job extends events.EventEmitter {
|
|||||||
}
|
}
|
||||||
|
|
||||||
_claimPendingJobs(jobs) {
|
_claimPendingJobs(jobs) {
|
||||||
if (jobs.length === 0) return;
|
if (!jobs || jobs.length === 0) return;
|
||||||
|
|
||||||
this._stopJobPolling();
|
this._stopJobPolling();
|
||||||
let claimed = false;
|
let claimed = false;
|
||||||
@@ -268,7 +268,7 @@ export default class Job extends events.EventEmitter {
|
|||||||
})
|
})
|
||||||
.catch((err) => {
|
.catch((err) => {
|
||||||
// ignore missing indices errors
|
// ignore missing indices errors
|
||||||
if (err.status === 404) return;
|
if (err.status === 404) return [];
|
||||||
|
|
||||||
this.debug('job querying failed', err);
|
this.debug('job querying failed', err);
|
||||||
this.emit('error', err);
|
this.emit('error', err);
|
||||||
|
|||||||
Reference in New Issue
Block a user