Important RingBuffBytesSender fix on non batched mode! & downgrade nix-shell python to lowest supported
parent
0208a4728f
commit
32b5210648
|
@ -13,6 +13,6 @@ pkgs.mkShell {
|
||||||
|
|
||||||
shellHook = ''
|
shellHook = ''
|
||||||
set -e
|
set -e
|
||||||
uv venv .venv --python=3.12
|
uv venv .venv --python=3.11
|
||||||
'';
|
'';
|
||||||
}
|
}
|
||||||
|
|
|
@ -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
|
||||||
|
|
Loading…
Reference in New Issue