Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Use lists by default like msgspec, update to latest msgspec and msgpack releases #300

Merged
merged 9 commits into from
Feb 15, 2022
Merged

Use lists by default like msgspec, update to latest msgspec and msgpack releases #300

Show file tree
Hide file tree
Changes from 3 commits
Commits
Show all changes
9 commits
Select commit Hold shift + click to select a range
77ddc07
Use lists by default like `msgspec`
goodboy Feb 7, 2022
17bfa12
Port to msgpec `0.4.0` imports
goodboy Feb 14, 2022
927decc
Pin to latest `msgspec` version
goodboy Feb 14, 2022
c65756e
Add nooz
goodboy Feb 14, 2022
17e195a
They renamed to `msgpack` and the version is 1.0.3
goodboy Feb 14, 2022
c5acc3b
Pack tuple keys as . delim strs in registry tests
goodboy Feb 15, 2022
0edc6a2
Go back to strict map keys
goodboy Feb 15, 2022
4eab4a0
Type fix
goodboy Feb 9, 2022
76a0492
Fix type annot
goodboy Feb 15, 2022
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion setup.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -62,7 +62,7 @@
extras_require={

# serialization
'msgspec': ["msgspec >= 0.3.2'; python_version >= '3.9'"],
'msgspec': ['msgspec >= "0.4.0"'],

},
tests_require=['pytest'],
Expand Down
8 changes: 4 additions & 4 deletions tractor/_ipc.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -96,7 +96,8 @@ def raddr(self) -> Tuple[str, int]:


class MsgpackTCPStream:
'''A ``trio.SocketStream`` delivering ``msgpack`` formatted data
'''
A ``trio.SocketStream`` delivering ``msgpack`` formatted data
using ``msgpack-python``.

'''
Expand Down Expand Up @@ -124,7 +125,6 @@ async def _iter_packets(self) -> AsyncGenerator[dict, None]:
"""
unpacker = msgpack.Unpacker(
raw=False,
use_list=False,
strict_map_key=False
)
while True:
Expand Down Expand Up @@ -222,8 +222,8 @@ def __init__(
self.prefix_size = prefix_size

# TODO: struct aware messaging coders
self.encode = msgspec.Encoder().encode
self.decode = msgspec.Decoder().decode # dict[str, Any])
self.encode = msgspec.msgpack.Encoder().encode
self.decode = msgspec.msgpack.Decoder().decode # dict[str, Any])

async def _iter_packets(self) -> AsyncGenerator[dict, None]:
'''Yield packets from the underlying stream.
Expand Down