(queue, pause)
| 53 | }, |
| 54 | |
| 55 | pause(queue, pause) { |
| 56 | let src = 'wait', |
| 57 | dst = 'paused'; |
| 58 | if (!pause) { |
| 59 | src = 'paused'; |
| 60 | dst = 'wait'; |
| 61 | } |
| 62 | |
| 63 | const keys = _.map( |
| 64 | [src, dst, 'meta-paused', pause ? 'paused' : 'resumed', 'meta'], |
| 65 | name => { |
| 66 | return queue.toKey(name); |
| 67 | } |
| 68 | ); |
| 69 | |
| 70 | return queue.client.pause(keys.concat([pause ? 'paused' : 'resumed'])); |
| 71 | }, |
| 72 | |
| 73 | async addLog(queue, jobId, logRow, keepLogs) { |
| 74 | const client = await queue.client; |