(self, amt, request_token, time_now)
| 289 | return self._release_requested_amt(amt, time_now) |
| 290 | |
| 291 | def _raise_request_exceeded_exception(self, amt, request_token, time_now): |
| 292 | allocated_time = amt / float(self._max_rate) |
| 293 | retry_time = self._consumption_scheduler.schedule_consumption( |
| 294 | amt, request_token, allocated_time |
| 295 | ) |
| 296 | raise RequestExceededException( |
| 297 | requested_amt=amt, retry_time=retry_time |
| 298 | ) |
| 299 | |
| 300 | def _release_requested_amt(self, amt, time_now): |
| 301 | self._rate_tracker.record_consumption_rate(amt, time_now) |
no test coverage detected