(
self, *, retries_taken: int, max_retries: int, options: FinalRequestOptions, response: httpx.Response | None
)
| 1728 | ) |
| 1729 | |
| 1730 | async def _sleep_for_retry( |
| 1731 | self, *, retries_taken: int, max_retries: int, options: FinalRequestOptions, response: httpx.Response | None |
| 1732 | ) -> None: |
| 1733 | remaining_retries = max_retries - retries_taken |
| 1734 | if remaining_retries == 1: |
| 1735 | log.debug("1 retry left") |
| 1736 | else: |
| 1737 | log.debug("%i retries left", remaining_retries) |
| 1738 | |
| 1739 | timeout = self._calculate_retry_timeout(remaining_retries, options, response.headers if response else None) |
| 1740 | log.info("Retrying request to %s in %f seconds", options.url, timeout) |
| 1741 | |
| 1742 | await anyio.sleep(timeout) |
| 1743 | |
| 1744 | async def _process_response( |
| 1745 | self, |
no test coverage detected