(self)
| 4439 | self._timer = self.session.cluster.connection_class.create_timer(self._time_remaining, self._on_timeout) |
| 4440 | |
| 4441 | def _cancel_timer(self): |
| 4442 | if self._timer: |
| 4443 | self._timer.cancel() |
| 4444 | |
| 4445 | def _on_timeout(self, _attempts=0): |
| 4446 | """ |
no test coverage detected