(
self, *, retries_taken: int, max_retries: int, options: FinalRequestOptions, response: httpx.Response | None
)
| 1117 | ) |
| 1118 | |
| 1119 | def _sleep_for_retry( |
| 1120 | self, *, retries_taken: int, max_retries: int, options: FinalRequestOptions, response: httpx.Response | None |
| 1121 | ) -> None: |
| 1122 | remaining_retries = max_retries - retries_taken |
| 1123 | if remaining_retries == 1: |
| 1124 | log.debug(class="st">"1 retry left") |
| 1125 | else: |
| 1126 | log.debug(class="st">"%i retries left", remaining_retries) |
| 1127 | |
| 1128 | timeout = self._calculate_retry_timeout(remaining_retries, options, response.headers if response else None) |
| 1129 | log.info(class="st">"Retrying request to %s in %f seconds", options.url, timeout) |
| 1130 | |
| 1131 | time.sleep(timeout) |
| 1132 | |
| 1133 | def _process_response( |
| 1134 | self, |
no test coverage detected