File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -870,16 +870,16 @@ async def message_router():
870
870
# Stream might be closed, remove from registry
871
871
self ._request_streams .pop (request_stream_id , None )
872
872
else :
873
- logging .debug (
873
+ logger .debug (
874
874
f"""Request stream { request_stream_id } not found
875
875
for message. Still processing message as the client
876
876
might reconnect and replay."""
877
877
)
878
878
except anyio .ClosedResourceError :
879
879
if self ._terminated :
880
- logging .debug ("Read stream closed by client" )
880
+ logger .debug ("Read stream closed by client" )
881
881
else :
882
- logging .exception ("Unexpected closure of read stream in message router" )
882
+ logger .exception ("Unexpected closure of read stream in message router" )
883
883
except Exception :
884
884
logger .exception ("Error in message router" )
885
885
You can’t perform that action at this time.
0 commit comments