interface.debug will now also print errors
This commit is contained in:
@@ -38,7 +38,7 @@ import logging
|
|||||||
import aiorpcx
|
import aiorpcx
|
||||||
from aiorpcx import RPCSession, Notification, NetAddress
|
from aiorpcx import RPCSession, Notification, NetAddress
|
||||||
from aiorpcx.curio import timeout_after, TaskTimeout
|
from aiorpcx.curio import timeout_after, TaskTimeout
|
||||||
from aiorpcx.jsonrpc import JSONRPC
|
from aiorpcx.jsonrpc import JSONRPC, CodeMessageError
|
||||||
from aiorpcx.rawsocket import RSClient
|
from aiorpcx.rawsocket import RSClient
|
||||||
import certifi
|
import certifi
|
||||||
|
|
||||||
@@ -115,6 +115,9 @@ class NotificationSession(RPCSession):
|
|||||||
timeout)
|
timeout)
|
||||||
except (TaskTimeout, asyncio.TimeoutError) as e:
|
except (TaskTimeout, asyncio.TimeoutError) as e:
|
||||||
raise RequestTimedOut(f'request timed out: {args} (id: {msg_id})') from e
|
raise RequestTimedOut(f'request timed out: {args} (id: {msg_id})') from e
|
||||||
|
except CodeMessageError as e:
|
||||||
|
self.maybe_log(f"--> {repr(e)} (id: {msg_id})")
|
||||||
|
raise
|
||||||
else:
|
else:
|
||||||
self.maybe_log(f"--> {response} (id: {msg_id})")
|
self.maybe_log(f"--> {response} (id: {msg_id})")
|
||||||
return response
|
return response
|
||||||
|
|||||||
Reference in New Issue
Block a user