(checkpoint, session)
| 9471 | } |
| 9472 | |
| 9473 | updateSource(checkpoint, session) { |
| 9474 | if (this.opts.writeSourceCheckpoint) { |
| 9475 | var self = this; |
| 9476 | return updateCheckpoint(this.src, this.id, checkpoint, |
| 9477 | session, this.returnValue) |
| 9478 | .catch(function (err) { |
| 9479 | if (isForbiddenError(err)) { |
| 9480 | self.opts.writeSourceCheckpoint = false; |
| 9481 | return true; |
| 9482 | } |
| 9483 | throw err; |
| 9484 | }); |
| 9485 | } else { |
| 9486 | return Promise.resolve(true); |
| 9487 | } |
| 9488 | } |
| 9489 | |
| 9490 | getCheckpoint() { |
| 9491 | var self = this; |
no test coverage detected