gabriel / muse public
feat patch task/phase14-server-side-object-streaming #2 / 3
AI Agent gabriel · 49 days ago · Apr 23, 2026 · Diff

feat: Phase 14A/B — inline object streaming, OC-frame protocol

Phase 14A (transport.py, push.py): - Raise LARGE_OBJECT_THRESHOLD 64 KB → 290 KB (matching OC_CHUNK_SIZE) - Add OC_CHUNK_SIZE = 290 * 1024 exported constant - Export _BATCH_BYTE_TARGET = 350 * 1024 at module level - Remove presign split in _push_stream: all objects go through split_object_into_oc_frames → batch loop (no client R2 PUTs for any object ≤ 290 KB)

Phase 14B (transport.py): - Add split_object_into_oc_frames(obj) → list[dict]: objects ≤ OC_CHUNK_SIZE → single O-frame dict objects > OC_CHUNK_SIZE → list of OC-frame dicts with chunk_index, total_chunks, content slice; metadata (encoding, path, sz) on chunk_index=0 only

Test fixes: - test_wire_h2_async_push.py: wrap mock response frames in 5-byte gRPC prefix (_grpc_wrap helper) — broken by Phase 13 gRPC-only switch, not noticed until now

All 90 wire tests pass.

sha256:e87b350357f084c4e4fcfc74abc557a4809ff56259424df7c013ad7fd8b0dac1 sha
sha256:d434f75fc4ce3b620a688a4469ba03b4adc78c4fb058c77dbf6074636be9b8b1 parent
sha256:f956caf8d284b723ebe49983b80c17971bae3ca37401598c35ba5934c5661332 snapshot
Older feat: Phase 14 plan + TDD — server-side object streaming (OC fra… sha256:d434f75fc4ce3b620a688a4469ba03b4adc78c4fb058c77dbf6074636be9b8b1 All commits Newer fix(wire): keep all OC chunks for an object in the same batch sha256:929e9cd18fc1b1cf7fc631ebb934213767d1c78311599ef25e7f16242a2f7586

0 comments

No comments yet. Be the first to start the discussion.

To add a comment, use the Muse CLI: muse hub commit comment sha256:e87b350357f084c4e4fcfc74abc557a4809ff56259424df7c013ad7fd8b0dac1 --body "your comment"