Skip to content

Commit 44c1d5c

Browse files
committed
Coerce the small bytes header of a message to bytes
UCX was producing memoryviews here, and they seemed to be malformed. Coercing to bytes seems foolproof and cheap (these should always be small)
1 parent c0ffeff commit 44c1d5c

1 file changed

Lines changed: 1 addition & 0 deletions

File tree

distributed/protocol/core.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -192,6 +192,7 @@ def loads_msgpack(header, payload):
192192
See Also:
193193
dumps_msgpack
194194
"""
195+
header = bytes(header)
195196
if header:
196197
header = msgpack.loads(header, use_list=False, **msgpack_opts)
197198
else:

0 commit comments

Comments
 (0)