From 68133e8be5cf63b6d90c8c38a3a4ff7954f67674 Mon Sep 17 00:00:00 2001 From: Dan <14043624+delivrance@users.noreply.github.com> Date: Thu, 14 Jun 2018 03:26:08 +0200 Subject: [PATCH] Better logs --- pyrogram/session/session.py | 17 ++++++++--------- 1 file changed, 8 insertions(+), 9 deletions(-) diff --git a/pyrogram/session/session.py b/pyrogram/session/session.py index ba224f46..ba0013cc 100644 --- a/pyrogram/session/session.py +++ b/pyrogram/session/session.py @@ -209,8 +209,7 @@ class Session: self.start() async def net_worker(self): - name = threading.current_thread().name - log.debug("{} started".format(name)) + log.info("NetWorkerTask started") while True: packet = await self.recv_queue.get() @@ -277,10 +276,10 @@ class Session: except Exception as e: log.error(e, exc_info=True) - log.debug("{} stopped".format(name)) + log.info("NetWorkerTask stopped") async def ping(self): - log.debug("Ping Task started") + log.info("PingTask started") while True: try: @@ -298,10 +297,10 @@ class Session: except (OSError, TimeoutError, Error): pass - log.debug("Ping Task stopped") + log.info("PingTask stopped") async def next_salt(self): - log.debug("NextSaltThread started") + log.info("NextSaltTask started") while True: now = datetime.now() @@ -331,10 +330,10 @@ class Session: self.connection.close() break - log.debug("NextSaltThread stopped") + log.info("NextSaltTask stopped") async def recv(self): - log.debug("Recv Task started") + log.info("RecvTask started") while True: packet = await self.connection.recv() @@ -350,7 +349,7 @@ class Session: self.recv_queue.put_nowait(packet) - log.debug("Recv Task stopped") + log.info("RecvTask stopped") async def _send(self, data: Object, wait_response: bool = True): message = self.msg_factory(data)