Method _poll_using_backoff

dwave/cloud/client/base.py:1599–1625

(self, future: Future)

            raise RuntimeError("unexpected polling strategy")

    def _poll_using_backoff(self, future: Future) -> None:
        if future._poll_backoff is None:
            # on first poll, start with minimal back-off
            future._poll_backoff = self.config.polling_schedule.backoff_min
        else:
            # on subsequent polls, do exponential back-off, clipped to a range
            future._poll_backoff = \
                max(self.config.polling_schedule.backoff_min,
                    min(future._poll_backoff * self.config.polling_schedule.backoff_base,
                        self.config.polling_schedule.backoff_max))

        # for poll priority we use timestamp of next scheduled poll
        at = time.time() + future._poll_backoff

        now = utcnow()
        future_age = (now - future.time_created).total_seconds()
        logger.debug("Polling scheduled at %.2f with %.2f sec new back-off for: %s (future's age: %.2f sec)",
                     at, future._poll_backoff, future.id, future_age)

        # don't enqueue for next poll if polling_timeout is exceeded by then
        future_age_on_next_poll = future_age + (at - datetime_to_timestamp(now))
        if self.config.polling_timeout is not None and future_age_on_next_poll > self.config.polling_timeout:
            logger.debug("Polling timeout exceeded before next poll: %.2f sec > %.2f sec, aborting polling!",
                         future_age_on_next_poll, self.config.polling_timeout)
            raise PollingTimeout

        self._poll_queue.put((at, future))

    def _poll_using_long_polling(self, future: Future) -> None:
        # we use problem submit time to prioritize polling of jobs submitted earlier