jc211
/
tractor
forked from goodboy/tractor
1
0
Fork 0
Code Pull Requests Activity

Decode bytes prior to log msg

drop_msgpack
Tyler Goodlet 2022-06-26 16:23:38 -04:00
parent 932b841176
commit 673c4a8c66
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
tractor/_ipc.py
View File

@ -185,10 +185,11 @@ class MsgpackTCPStream(MsgTransport):
# ignore decoding errors for now and assume they have to # ignore decoding errors for now and assume they have to
# do with a channel drop - hope that receiving from the # do with a channel drop - hope that receiving from the
# channel will raise an expected error and bubble up. # channel will raise an expected error and bubble up.
decoded_bytes = msg_bytes.decode()
log.error( log.error(
'`msgspec` failed to decode!?\n' '`msgspec` failed to decode!?\n'
'dumping bytes:\n' 'dumping bytes:\n'
f'{msg_bytes}' f'{decoded_bytes}'
) )
decodes_failed += 1 decodes_failed += 1
else: else: