(checkpoint, session)
| 9500 | } |
| 9501 | |
| 9502 | updateSource(checkpoint, session) { |
| 9503 | if (this.opts.writeSourceCheckpoint) { |
| 9504 | var self = this; |
| 9505 | return updateCheckpoint(this.src, this.id, checkpoint, |
| 9506 | session, this.returnValue) |
| 9507 | .catch(function (err) { |
| 9508 | if (isForbiddenError(err)) { |
| 9509 | self.opts.writeSourceCheckpoint = false; |
| 9510 | return true; |
| 9511 | } |
| 9512 | throw err; |
| 9513 | }); |
| 9514 | } else { |
| 9515 | return Promise.resolve(true); |
| 9516 | } |
| 9517 | } |
| 9518 | |
| 9519 | getCheckpoint() { |
| 9520 | var self = this; |
no test coverage detected