| 413 | return message |
| 414 | |
| 415 | async def _handle_error_interval(self, error_interval: float): |
| 416 | logger.debug('Waiting for %s seconds before retrying', error_interval) |
| 417 | await asyncio.sleep(error_interval) |
| 418 | if error_interval * 2 < 60: # same logic as sync |
| 419 | error_interval *= 2 |
| 420 | else: |
| 421 | error_interval = 60 |
| 422 | return error_interval |
| 423 | |
| 424 | async def _process_polling(self, non_stop: bool=False, interval: int=0, timeout: int=20, |
| 425 | request_timeout: int=None, allowed_updates: Optional[List[str]]=None): |