(cb)
| 193 | } |
| 194 | |
| 195 | retry(cb) { |
| 196 | const promise = this.queue |
| 197 | ._commandable() |
| 198 | .then((client) => |
| 199 | helpers.callAsync((done) => |
| 200 | client |
| 201 | .multi() |
| 202 | .srem(this.queue.toKey('failed'), this.id) |
| 203 | .lpush(this.queue.toKey('waiting'), this.id) |
| 204 | .exec(done) |
| 205 | ) |
| 206 | ); |
| 207 | |
| 208 | if (cb) helpers.asCallback(promise, cb); |
| 209 | return promise; |
| 210 | } |
| 211 | |
| 212 | isInSet(set, cb) { |
| 213 | const promise = this.queue |
no test coverage detected