gabriel / musehub public
feat BREAKING wire task/streaming-object-fetch #1 / 1
gabriel · 65 days ago · Apr 15, 2026 · Diff

feat(wire): stream fetch/objects via msgpack-stream for TTFO improvement

Replace buffered _pack_objects_response with _stream_objects async generator using asyncio.as_completed — objects are written to the response as each R2 GET completes instead of waiting for all fetches.

Changes: - New _MSGPACK_STREAM_CT = 'application/x-msgpack-stream' content type - New _stream_objects() async generator (asyncio.as_completed, 32-worker semaphore) - fetch_objects route now returns StreamingResponse(_stream_objects(...)) - 23 new tests across 8 tiers in test_wire_object_streaming.py

sha256:93ca3b437a654dd019ba1fd795bf30877d35628eb95ace1823db9bc76a92132f sha
sha256:2af4343389565ac145e376403ce4d851f75be40948463fb7f2ddd68e458cf2f7 parent
sha256:0d42b37f3d22b912ad228f3bb8ae012a4c2acf028511e8e1cef66f98b4d0f55c snapshot
← Older Oldest on task/streaming-object-fetch
All commits
Newer → Latest on task/streaming-object-fetch

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:93ca3b437a654dd019ba1fd795bf30877d35628eb95ace1823db9bc76a92132f --body "your comment"