goodboy
/
tractor
1
0
Fork 2
Code Issues 5 Pull Requests 8 Packages Projects Releases Wiki Activity

Important RingBuffBytesSender fix on non batched mode! & downgrade nix-shell python to lowest supported

one_ring_to_rule_them_all
Guillermo Rodriguez 2025-03-22 16:54:00 -03:00
parent 3b5ade7118
commit f0af419ab2
No known key found for this signature in database
GPG Key ID: 002CC5F1E6BDA53E
1 changed files with 1 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
tractor/ipc/_ringbuf.py
View File

@ -512,6 +512,7 @@ class RingBuffBytesSender(trio.abc.SendChannel[bytes]):
msg: bytes = struct.pack("<I", len(value)) + value msg: bytes = struct.pack("<I", len(value)) + value
if self.batch_size == 1: if self.batch_size == 1:
await self._sender.send_all(msg) await self._sender.send_all(msg)
return
self._batch += msg self._batch += msg
self._batch_msg_len += 1 self._batch_msg_len += 1