gabriel / muse public
refactor BREAKING task/phase4-cleanup #1 / 1
AI Agent gabriel · 156 days ago · Apr 23, 2026 · Diff

refactor: remove gRPC push_stream, add file:// push_stream_coro, delete dead tests (Phase 4)

sha256:ec44b2a960c4a1926961011945520e1a0134db0470e6b9a4784fdda43cd03701 sha
sha256:e6bc411a8b128ccf666c78018e4b26d69caa491a1b621b7fb410275c78fe18bc parent
+3 ~18 −109 symbols
sha256:600c6e5f900299d25ffd1c2e51c4469ba6b96798c6bc59783947173a8b46f99e snapshot
+3
symbols added
~18
symbols modified
−109
symbols removed
−1
dead symbol removed
Semantic Changes 130 symbols
~ tests/test_transport_http2.py .py 22 symbols removed
− TestT12PushStreamHttp2 class class TestT12PushStreamHttp2 L66–121
− _make_mock_client method method _make_mock_client L69–72
− _push method method _push L74–95
− test_http_url_also_uses_httpx method method test_http_url_also_uses_httpx L116–121
− test_httpx_stream_called method method test_httpx_stream_called L97–100
− test_httpx_stream_posts_to_push_stream_endpoint method method test_httpx_stream_posts_to_push_stream_endpoint L102–109
− test_result_ok_parsed_from_r_frame method method test_result_ok_parsed_from_r_frame L111–114
− _async_client_mock function function _async_client_mock L54–59
− _async_streaming_resp function function _async_streaming_resp L38–51
− _make_objects function function _make_objects L31–35
− _make_progress_frame function function _make_progress_frame L27–28
− _make_result_frame function function _make_result_frame L23–24
− _oid function function _oid L19–20
− AsyncMock import import AsyncMock L10–10
− MagicMock import import MagicMock L10–10
− ObjectPayload import import ObjectPayload L15–15
− PushResult import import PushResult L15–15
− annotations import import annotations L8–8
− blob_id import import blob_id L16–16
− msgpack import import msgpack L12–12
− patch import import patch L10–10
− pytest import import pytest L13–13
~ tests/test_wire_h2_async_push.py .py 49 symbols removed
− TestT25AsyncClientUsed class class TestT25AsyncClientUsed L131–177
− _make_mock_httpx method method _make_mock_httpx L134–141
− test_async_client_has_http2_true method method test_async_client_has_http2_true L163–171
− test_async_client_is_instantiated method method test_async_client_is_instantiated L143–147
− test_result_ok_returned method method test_result_ok_returned L173–177
− test_sync_client_is_not_used_for_streaming_post method method test_sync_client_is_not_used_for_streaming_post L149–161
− TestT26BidirectionalNoDeadlock class class TestT26BidirectionalNoDeadlock L184–224
− _make_mock_httpx_with_progress method method _make_mock_httpx_with_progress L193–202
− test_async_stream_content_generator_is_consumed method method test_async_stream_content_generator_is_consumed L216–224
− test_push_completes_with_interleaved_response_frames method method test_push_completes_with_interleaved_response_frames L204–208
− test_push_with_many_objects_completes method method test_push_with_many_objects_completes L210–214
− TestT27FrameSequence class class TestT27FrameSequence L231–345
− _collect_frames method method _collect_frames L234–279
− test_c_frame_after_all_o_frames method method test_c_frame_after_all_o_frames L292–297
− test_e_frame_is_last method method test_e_frame_is_last L299–301
− test_h_frame_is_first method method test_h_frame_is_first L281–283
− test_mwp_magic_in_every_envelope method method test_mwp_magic_in_every_envelope L309–333
− test_mwp_version_byte_is_1 method method test_mwp_version_byte_is_1 L335–345
− test_o_frames_follow_h method method test_o_frames_follow_h L285–290
− test_object_count_matches method method test_object_count_matches L303–307
− TestT28WriteErrorMapped class class TestT28WriteErrorMapped L352–416
− _make_mock_httpx_write_error method method _make_mock_httpx_write_error L355–371
− test_write_error_message_is_informative method method test_write_error_message_is_informative L393–416
− test_write_error_raises_transport_error method method test_write_error_raises_transport_error L373–391
− _aiter function async_function _aiter L72–74
− _async_client_mock function function _async_client_mock L96–102
− _async_streaming_response function function _async_streaming_response L77–93
− _do_push function function _do_push L105–124
− _grpc_wrap function function _grpc_wrap L41–44
− _make_objects function function _make_objects L65–69
− _mwp_wrap function function _mwp_wrap L60–62
− _oid function function _oid L37–38
− _progress_frame function function _progress_frame L55–57
− _result_frame function function _result_frame L47–52
− Any import import Any L22–22
− AsyncIterator import import AsyncIterator L21–21
− AsyncMock import import AsyncMock L23–23
− MPackStreamWriter import import MPackStreamWriter L29–29
− MagicMock import import MagicMock L23–23
− MuseWireFrameWriter import import MuseWireFrameWriter L29–29
− ObjectPayload import import ObjectPayload L30–30
− PushResult import import PushResult L30–30
− annotations import import annotations L17–17
− asyncio import import asyncio L19–19
− blob_id import import blob_id L28–28
− msgpack import import msgpack L25–25
− patch import import patch L23–23
− pytest import import pytest L26–26
− struct import import struct L20–20
~ tests/test_wire_h2_wall17.py .py 24 symbols removed
− TestT25ZeroObjectPush class class TestT25ZeroObjectPush L74–127
− test_zero_object_push_result_has_expected_shape method method test_zero_object_push_result_has_expected_shape L97–111
− test_zero_object_push_sends_exactly_one_post method method test_zero_object_push_sends_exactly_one_post L113–127
− test_zero_object_push_succeeds method method test_zero_object_push_succeeds L83–95
− TestT26WriteErrorDiagnostic class class TestT26WriteErrorDiagnostic L135–223
− _make_resp_that_raises method method _make_resp_that_raises L145–158
− test_empty_write_error_no_cause_reports_rst_stream method method test_empty_write_error_no_cause_reports_rst_stream L184–203
− test_empty_write_error_with_cause_includes_cause_text method method test_empty_write_error_with_cause_includes_cause_text L160–182
− test_non_empty_write_error_passes_through_unchanged method method test_non_empty_write_error_passes_through_unchanged L205–223
− TestT27SSLErrorWrapped class class TestT27SSLErrorWrapped L231–288
− _make_resp_aenter_raises method method _make_resp_aenter_raises L240–249
− test_ssl_error_bad_record_mac_wraps_to_transport_error method method test_ssl_error_bad_record_mac_wraps_to_transport_error L251–266
− test_ssl_error_is_not_raised_raw method method test_ssl_error_is_not_raised_raw L268–288
− _async_mock_httpx_streaming_response function function _async_mock_httpx_streaming_response L31–43
− _mock_httpx_client function function _mock_httpx_client L46–51
− _push_zero_objects function function _push_zero_objects L54–66
− _result_frame function function _result_frame L27–28
− AsyncMock import import AsyncMock L14–14
− MagicMock import import MagicMock L14–14
− PushResult import import PushResult L19–19
− annotations import import annotations L12–12
− msgpack import import msgpack L16–16
− patch import import patch L14–14
− pytest import import pytest L17–17
~ docs/protocol/push-v2.md .md 3 symbols modified
~ Muse Push v2 — GitHub-Class Transport Plan
~ Status (as of 2026-04-23)
~ table@L131
~ muse/cli/commands/push.py .py 1 symbol modified
~ _push_stream
~ muse/core/transport.py .py 1 symbol added, 1 symbol removed, 2 symbols modified
− push_stream method method push_stream L1014–1238
+ push_stream_coro method async_method push_stream_coro L1997–2021
~ HttpTransport
~ LocalFileTransport
~ tests/test_push_have_filter.py .py 1 symbol added, 10 symbols modified
+ AsyncMock import import AsyncMock L43–43
~ TestE2EPushTwiceVII
~ test_VII1_push_then_push_new_commit_sends_one
~ test_VII2_push_idempotent_when_up_to_date
~ TestSecondPushDeltaV
~ test_V1_second_push_commit_count_is_one
~ test_V2_first_push_sends_all_commits
~ test_V3_have_from_live_remote_info
~ TestStressVIII
~ test_VIII1_200_commit_chain_second_push_delta_is_one
~ _push_mock
~ tests/test_wire_h2_strict.py .py 1 symbol added, 13 symbols removed, 2 symbols modified
− TestT16PushStreamNoFallback class class TestT16PushStreamNoFallback L122–181
− _make_error_mock_mod method method _make_error_mock_mod L125–137
− test_https_push_never_uses_http_client method method test_https_push_never_uses_http_client L159–181
− test_httpx_error_propagates_as_transport_error method method test_httpx_error_propagates_as_transport_error L139–157
− TestT22PushStreamNoRawConn class class TestT22PushStreamNoRawConn L288–312
− test_no_open_chunked_connection_on_success method method test_no_open_chunked_connection_on_success L291–312
− TestT24PushStreamFreshConnection class class TestT24PushStreamFreshConnection L319–375
− test_async_client_created_per_push method method test_async_client_created_per_push L327–349
− test_push_result_ok method method test_push_result_ok L351–375
− _make_objects function function _make_objects L55–56
− Iterator import import Iterator L17–17
− ObjectPayload import import ObjectPayload L23–23
− PushResult import import PushResult L23–23
+ _grpc_wrap function function _grpc_wrap L50–52
~ TestT17FetchStreamHttpx
~ _make_client_and_frames
← Older Oldest on task/phase4-cleanup
All commits
Newer → Latest on task/phase4-cleanup

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