interface: also log cancellations in send_request
This commit is contained in:
@@ -170,10 +170,14 @@ class NotificationSession(RPCSession):
|
|||||||
super().send_request(*args, **kwargs),
|
super().send_request(*args, **kwargs),
|
||||||
timeout)
|
timeout)
|
||||||
except (TaskTimeout, asyncio.TimeoutError) as e:
|
except (TaskTimeout, asyncio.TimeoutError) as e:
|
||||||
|
self.maybe_log(f"--> request timed out: {args} (id: {msg_id})")
|
||||||
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:
|
except CodeMessageError as e:
|
||||||
self.maybe_log(f"--> {repr(e)} (id: {msg_id})")
|
self.maybe_log(f"--> {repr(e)} (id: {msg_id})")
|
||||||
raise
|
raise
|
||||||
|
except BaseException as e: # cancellations, etc. are useful for debugging
|
||||||
|
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