diff --git a/src/wrpc/asyncio/client.py b/src/wrpc/asyncio/client.py index 8529ada..b5eedd7 100644 --- a/src/wrpc/asyncio/client.py +++ b/src/wrpc/asyncio/client.py @@ -190,11 +190,13 @@ class Client: ) if isinstance(frame.payload, str) else frame.payload) await self.writer.drain() return o - except: + except Exception as e: try: del self.frames[frame_id] except KeyError: pass + except: + logger.opt(exception=e).error('frame_id not assignment') raise def subscribe(self, topics):