diff --git a/default.nix b/default.nix index 5a936971..31615def 100644 --- a/default.nix +++ b/default.nix @@ -13,6 +13,6 @@ pkgs.mkShell { shellHook = '' set -e - uv venv .venv --python=3.12 + uv venv .venv --python=3.11 ''; } diff --git a/tractor/ipc/_ringbuf.py b/tractor/ipc/_ringbuf.py index 7d96eeda..10975b7a 100644 --- a/tractor/ipc/_ringbuf.py +++ b/tractor/ipc/_ringbuf.py @@ -512,6 +512,7 @@ class RingBuffBytesSender(trio.abc.SendChannel[bytes]): msg: bytes = struct.pack("<I", len(value)) + value if self.batch_size == 1: await self._sender.send_all(msg) + return self._batch += msg self._batch_msg_len += 1