(self)
| 4429 | return (self._start_time + self.timeout) - time.time() |
| 4430 | |
| 4431 | def _start_timer(self): |
| 4432 | if self._timer is None: |
| 4433 | spec_delay = self._spec_execution_plan.next_execution(self._current_host) |
| 4434 | if spec_delay >= 0: |
| 4435 | if self._time_remaining is None or self._time_remaining > spec_delay: |
| 4436 | self._timer = self.session.cluster.connection_class.create_timer(spec_delay, self._on_speculative_execute) |
| 4437 | return |
| 4438 | if self._time_remaining is not None: |
| 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: |
no test coverage detected