(queue, {endDelay = 1} = {})
| 54 | } |
| 55 | |
| 56 | async function forceStall(queue, {endDelay = 1} = {}) { |
| 57 | // Safety belts. |
| 58 | await helpers.delay(1); |
| 59 | await queue.checkStalledJobs(); |
| 60 | await helpers.callAsync((done) => |
| 61 | // This key prevents frequent running of the stall check as that would |
| 62 | // cause erroneous stalls, and its removal unblocks the discovery of |
| 63 | // stalled jobs. |
| 64 | queue.client.del(queue.toKey('stallBlock'), done) |
| 65 | ); |
| 66 | // Safety belts. |
| 67 | await helpers.delay(endDelay); |
| 68 | } |
| 69 | |
| 70 | function spitter() { |
| 71 | const values = [], |
no test coverage detected