mirror of
https://github.com/Mayuri-Chan/pyrofork.git
synced 2026-01-11 00:44:50 +00:00
Log error in updates_invoke_error variable, on all invokes.
This commit is contained in:
parent
a82c14ae48
commit
3ee60ac43a
2 changed files with 5 additions and 6 deletions
|
|
@ -338,7 +338,7 @@ class Client(Methods):
|
|||
# after some idle time has been detected.
|
||||
self.updates_watchdog_task = None
|
||||
self.updates_watchdog_event = asyncio.Event()
|
||||
self.updates_watchdog_error = None
|
||||
self.updates_invoke_error = None
|
||||
self.last_update_time = datetime.now()
|
||||
self.listeners = {listener_type: [] for listener_type in pyrogram.enums.ListenerTypes}
|
||||
self.loop = asyncio.get_event_loop()
|
||||
|
|
@ -370,11 +370,8 @@ class Client(Methods):
|
|||
else:
|
||||
break
|
||||
|
||||
try:
|
||||
if datetime.now() - self.last_update_time > timedelta(seconds=self.UPDATES_WATCHDOG_INTERVAL):
|
||||
await self.invoke(raw.functions.updates.GetState())
|
||||
except Exception as ee:
|
||||
self.updates_watchdog_error = ee
|
||||
if datetime.now() - self.last_update_time > timedelta(seconds=self.UPDATES_WATCHDOG_INTERVAL):
|
||||
await self.invoke(raw.functions.updates.GetState())
|
||||
|
||||
async def authorize(self) -> User:
|
||||
if self.bot_token:
|
||||
|
|
|
|||
|
|
@ -423,3 +423,5 @@ class Session:
|
|||
await asyncio.sleep(0.5)
|
||||
|
||||
return await self.invoke(query, retries - 1, timeout)
|
||||
except Exception as ex:
|
||||
self.client.updates_invoke_error = ex
|
||||
|
|
|
|||
Loading…
Reference in a new issue