()
| 532 | } |
| 533 | |
| 534 | _getNextJob() { |
| 535 | this._redisFailureRetryDelay = 0; |
| 536 | // Under normal calling conditions, commandable will not reject because we |
| 537 | // will have just checked paused in Queue#process. |
| 538 | return this._commandable(true).then(() => this._waitForJob()); |
| 539 | } |
| 540 | |
| 541 | _runJob(job) { |
| 542 | let psTimeout = null, |
no test coverage detected