gabriel / muse public
refactor BREAKING task/delete-http1-chunked-path #1 / 1
AI Agent gabriel · 152 days ago · Apr 22, 2026 · Diff

refactor: delete HTTP/1.1 chunked push path — httpx only, one API

- Remove _open_chunked_connection, _send_chunked_frame, _send_terminal_chunk - push_stream now always routes through _push_stream_httpx (HTTP/2 via httpx) - Fix mpack.py: import CommitDict/SnapshotDict so get_type_hints() resolves them - Delete 7 old test files for the chunked/legacy push path - Update test_transport_http2.py: replace chunked test with httpx-only test - Document Wall 9 (b'b5ac' magic) and fix in musewire-performance.md

sha256:029d7cf086cab29eb05512c0cc83c8ac03bead53e40a815a167fc140c564a10d sha
+14 ~10 −435 symbols
sha256:3176c8e8bdc88cecfd8ec17c0b3b389cbdd94b6ec9d10fabf7bcc601ed852210 snapshot
+14
symbols added
~10
symbols modified
−435
symbols removed
−1
dead symbol removed
Semantic Changes 459 symbols
~ tests/test_cli_stream_push.py .py 121 symbols removed
DeltaRepoInfo class class DeltaRepoInfo L910–915
TestT10DeltaEncoding class class TestT10DeltaEncoding L1084–1166
_run_delta method method _run_delta L1087–1110
test_delta_encoding_used_for_changed_file method method test_delta_encoding_used_for_changed_file L1112–1120
test_delta_object_has_base_id method method test_delta_object_has_base_id L1130–1136
test_delta_object_has_correct_encoding_field method method test_delta_object_has_correct_encoding_field L1122–1128
test_delta_object_has_sz_set_to_raw_size method method test_delta_object_has_sz_set_to_raw_size L1138–1145
test_no_delta_for_new_file method method test_no_delta_for_new_file L1157–1166
test_no_delta_without_branch_have method method test_no_delta_without_branch_have L1147–1155
TestT13InitSentinel class class TestT13InitSentinel L766–836
_setup method method _setup L779–785
test_empty_branch_heads_still_works method method test_empty_branch_heads_still_works L829–836
test_init_sentinel_not_included_in_have_list method method test_init_sentinel_not_included_in_have_list L798–810
test_other_valid_refs_still_included_in_have method method test_other_valid_refs_still_included_in_have L812–827
test_push_to_empty_remote_does_not_crash method method test_push_to_empty_remote_does_not_crash L787–796
TestT1ObjectPayload class class TestT1ObjectPayload L132–163
test_object_payload_minimal_construction method method test_object_payload_minimal_construction L135–140
test_object_payload_with_path method method test_object_payload_with_path L149–153
test_object_payload_with_zlib_encoding method method test_object_payload_with_zlib_encoding L142–147
test_push_result_failure method method test_push_result_failure L160–163
test_push_result_ok method method test_push_result_ok L155–158
TestT2PushStreamWiring class class TestT2PushStreamWiring L170–235
_call_push_stream method method _call_push_stream L173–192
test_no_old_methods_called method method test_no_old_methods_called L225–235
test_returns_push_result_and_counts method method test_returns_push_result_and_counts L217–223
test_transport_push_stream_branch_passed method method test_transport_push_stream_branch_passed L199–203
test_transport_push_stream_called_once method method test_transport_push_stream_called_once L194–197
test_transport_push_stream_force_false_by_default method method test_transport_push_stream_force_false_by_default L205–209
test_transport_push_stream_force_true_passed_through method method test_transport_push_stream_force_true_passed_through L211–215
TestT3Compression class class TestT3Compression L242–273
test_compress_zlib_is_smaller_or_equal_for_random_data method method test_compress_zlib_is_smaller_or_equal_for_random_data L257–263
test_compress_zlib_output_is_decompressible method method test_compress_zlib_output_is_decompressible L245–249
test_compress_zlib_reduces_size_for_repetitive_data method method test_compress_zlib_reduces_size_for_repetitive_data L251–255
test_sha256_of_raw_matches_oid_not_compressed method method test_sha256_of_raw_matches_oid_not_compressed L265–273
TestT4CommitWalkBoundary class class TestT4CommitWalkBoundary L280–309
test_walk_excludes_commits_reachable_from_branch_have method method test_walk_excludes_commits_reachable_from_branch_have L283–294
test_walk_includes_commits_not_in_have method method test_walk_includes_commits_not_in_have L296–302
test_walk_returns_oid_to_path_map method method test_walk_returns_oid_to_path_map L304–309
TestT5PushStreamLifecycle class class TestT5PushStreamLifecycle L316–444
_run method method _run L319–340
test_commits_sent_oldest_first method method test_commits_sent_oldest_first L385–444
test_objects_passed_as_raw_to_transport method method test_objects_passed_as_raw_to_transport L353–383
test_sends_commits_and_objects_on_fresh_push method method test_sends_commits_and_objects_on_fresh_push L342–345
test_sends_zero_commits_when_already_pushed method method test_sends_zero_commits_when_already_pushed L347–351
TestT6MPackFrameEncoding class class TestT6MPackFrameEncoding L458–632
_build_frames method method _build_frames L476–534
test_commit_pack_contains_commit method method test_commit_pack_contains_commit L598–604
test_commit_pack_frame_present method method test_commit_pack_frame_present L588–596
test_end_frame_object_count method method test_end_frame_object_count L612–618
test_first_frame_is_header method method test_first_frame_is_header L536–539
test_frame_order_h_o_c_e method method test_frame_order_h_o_c_e L620–632
test_header_contains_branch method method test_header_contains_branch L541–544
test_header_force_field method method test_header_force_field L546–549
test_header_have_list method method test_header_have_list L551–555
test_last_frame_is_end method method test_last_frame_is_end L606–610
test_raw_object_content_compressable method method test_raw_object_content_compressable L566–576
test_raw_object_frame_present method method test_raw_object_frame_present L557–564
test_zlib_object_enc_field_preserved method method test_zlib_object_enc_field_preserved L578–586
TestT7CliPushCommand class class TestT7CliPushCommand L639–692
_patch_transport method method _patch_transport L643–649
test_push_401_exits_nonzero_with_message method method test_push_401_exits_nonzero_with_message L670–675
test_push_404_prints_helpful_message method method test_push_404_prints_helpful_message L677–682
test_push_calls_push_stream_not_push_pack method method test_push_calls_push_stream_not_push_pack L657–661
test_push_dry_run_does_not_call_transport method method test_push_dry_run_does_not_call_transport L690–692
test_push_exits_zero_on_success method method test_push_exits_zero_on_success L651–655
test_push_force_flag_passed_to_transport method method test_push_force_flag_passed_to_transport L684–688
test_push_non_fast_forward_exits_nonzero method method test_push_non_fast_forward_exits_nonzero L663–668
TestT8ErrorPaths class class TestT8ErrorPaths L699–759
_patch_transport method method _patch_transport L703–709
test_push_delete_branch_does_not_call_push_stream method method test_push_delete_branch_does_not_call_push_stream L749–759
test_push_invalid_format_exits_nonzero method method test_push_invalid_format_exits_nonzero L745–747
test_push_stream_transport_error_generic method method test_push_stream_transport_error_generic L715–718
test_push_to_unconfigured_remote_exits_nonzero method method test_push_to_unconfigured_remote_exits_nonzero L711–713
test_push_up_to_date_is_reported method method test_push_up_to_date_is_reported L720–730
test_push_with_json_format_returns_valid_json method method test_push_with_json_format_returns_valid_json L732–743
TestT9ObjectChunking class class TestT9ObjectChunking L972–1077
_run method method _run L975–1000
test_each_batch_object_count_bounded method method test_each_batch_object_count_bounded L1049–1055
test_exact_chunk_boundary_is_one_call method method test_exact_chunk_boundary_is_one_call L1072–1077
test_final_batch_has_all_commits method method test_final_batch_has_all_commits L1032–1038
test_final_batch_has_local_head method method test_final_batch_has_local_head L1040–1047
test_large_push_calls_transport_multiple_times method method test_large_push_calls_transport_multiple_times L1002–1007
test_non_final_batches_have_no_commits method method test_non_final_batches_have_no_commits L1009–1015
test_non_final_batches_have_no_local_head method method test_non_final_batches_have_no_local_head L1024–1030
test_non_final_batches_have_no_snapshots method method test_non_final_batches_have_no_snapshots L1017–1022
test_small_push_still_one_call method method test_small_push_still_one_call L1065–1070
test_total_objects_across_batches_equals_objects_sent method method test_total_objects_across_batches_equals_objects_sent L1057–1063
_SFRAME_COMMIT_PACK variable variable _SFRAME_COMMIT_PACK L453–453
_SFRAME_END variable variable _SFRAME_END L454–454
_SFRAME_HEADER variable variable _SFRAME_HEADER L451–451
_SFRAME_OBJECT variable variable _SFRAME_OBJECT L452–452
_SFRAME_RESULT variable variable _SFRAME_RESULT L455–455
_build_commit function function _build_commit L855–887
_make_push_result function function _make_push_result L46–51
_mock_transport function function _mock_transport L120–125
_repo function function _repo L54–75
_sha256_oid function function _sha256_oid L42–43
_write_file_object function function _write_file_object L843–852
delta_repo function function delta_repo L919–965
Any import import Any L23–23
CliRunner import import CliRunner L32–32
MagicMock import import MagicMock L24–24
Mapping import import Mapping L17–17
ObjectPayload import import ObjectPayload L30–30
PushResult import import PushResult L30–30
TransportError import import TransportError L31–31
__version__ import import __version__ L29–29
annotations import import annotations L16–16
blob_id import import blob_id L33–33
call import import call L24–24
dataclass class import dataclass L906–906
io import import io L19–19
json import import json L20–20
msgpack import import msgpack L26–26
patch import import patch L24–24
pathlib import import pathlib L21–21
pytest import import pytest L27–27
zlib import import zlib L22–22
multi_object_repo function function multi_object_repo L891–903
repo function function repo L79–117
runner variable variable runner L35–35
~ tests/test_mpack_chunked_push.py .py 69 symbols removed
MockHTTPConnection class class MockHTTPConnection L93–126
__init__ method method __init__ L96–105
close method method close L125–126
endheaders method method endheaders L116–117
getresponse method method getresponse L122–123
putheader method method putheader L113–114
putrequest method method putrequest L107–111
send method method send L119–120
MockHTTPResponse class class MockHTTPResponse L72–90
__init__ method method __init__ L75–78
getheader method method getheader L89–90
read method method read L80–87
TestChunkedConnectionType class class TestChunkedConnectionType L485–554
_run_with_url method method _run_with_url L486–520
test_connection_closed_after_error method method test_connection_closed_after_error L548–554
test_connection_closed_after_success method method test_connection_closed_after_success L542–546
test_host_extracted_correctly method method test_host_extracted_correctly L532–535
test_http_url_uses_use_ssl_false method method test_http_url_uses_use_ssl_false L522–525
test_https_url_uses_use_ssl_true method method test_https_url_uses_use_ssl_true L527–530
test_port_extracted_correctly method method test_port_extracted_correctly L537–540
TestChunkedFrameSequence class class TestChunkedFrameSequence L350–422
test_each_object_is_separate_send method method test_each_object_is_separate_send L396–406
test_empty_push_has_h_c_e_terminal method method test_empty_push_has_h_c_e_terminal L370–379
test_h_frame_first_send method method test_h_frame_first_send L351–359
test_o_frames_between_h_and_c method method test_o_frames_between_h_and_c L381–394
test_send_count_matches_frame_count method method test_send_count_matches_frame_count L408–422
test_terminal_chunk_is_last_send method method test_terminal_chunk_is_last_send L361–368
TestChunkedHeaders class class TestChunkedHeaders L208–250
test_accept_is_mpack method method test_accept_is_mpack L232–236
test_content_type_is_mpack method method test_content_type_is_mpack L226–230
test_no_content_length method method test_no_content_length L217–224
test_path_ends_with_push_stream method method test_path_ends_with_push_stream L244–250
test_transfer_encoding_chunked method method test_transfer_encoding_chunked L209–215
test_uses_post_method method method test_uses_post_method L238–242
TestChunkedMemoryBounded class class TestChunkedMemoryBounded L430–477
test_no_single_send_contains_all_frames method method test_no_single_send_contains_all_frames L431–454
test_peak_send_size_bounded_per_object method method test_peak_send_size_bounded_per_object L456–477
TestChunkedResponseParsing class class TestChunkedResponseParsing L562–670
test_http_4xx_raises_transport_error method method test_http_4xx_raises_transport_error L619–642
test_no_result_frame_raises_transport_error method method test_no_result_frame_raises_transport_error L644–670
test_p_frame_does_not_raise method method test_p_frame_does_not_raise L607–617
test_r_frame_message_preserved method method test_r_frame_message_preserved L572–578
test_r_frame_ok_returns_push_result method method test_r_frame_ok_returns_push_result L563–570
test_x_frame_raises_transport_error method method test_x_frame_raises_transport_error L580–605
TestChunkedSigning class class TestChunkedSigning L258–342
test_auth_header_present_when_signed method method test_auth_header_present_when_signed L265–272
test_auth_not_signed_over_full_body method method test_auth_not_signed_over_full_body L305–342
test_auth_signed_over_empty_body method method test_auth_signed_over_empty_body L274–303
test_no_auth_header_when_unsigned method method test_no_auth_header_when_unsigned L259–263
_decode_mpack_frames function function _decode_mpack_frames L190–200
_decode_sends function function _decode_sends L176–187
_make_r_frame function function _make_r_frame L67–69
_make_signing function function _make_signing L56–58
_parse_chunk function function _parse_chunk L61–64
_run_push function function _run_push L129–173
BytesIO import import BytesIO L37–37
HttpTransport import import HttpTransport L47–47
MPACK_CONTENT_TYPE import import MPACK_CONTENT_TYPE L42–42
MPACK_VERSION import import MPACK_VERSION L42–42
MPackStreamWriter import import MPackStreamWriter L42–42
Mapping import import Mapping L34–34
SigningIdentity import import SigningIdentity L47–47
TransportError import import TransportError L47–47
annotations import import annotations L33–33
blob_id import import blob_id L48–48
long_id import import long_id L48–48
msgpack import import msgpack L39–39
pytest import import pytest L40–40
mock import import unittest.mock L36–36
~ tests/test_mpack_perf.py .py 29 symbols removed
TestApplyMpackThroughput class class TestApplyMpackThroughput L200–216
test_clone_simulation_500_commits_under_3s method method test_clone_simulation_500_commits_under_3s L201–216
TestBuildMpackThroughput class class TestBuildMpackThroughput L127–153
test_100_commit_chain_build_under_2s method method test_100_commit_chain_build_under_2s L128–138
test_build_and_apply_1000_objects_under_3s method method test_build_and_apply_1000_objects_under_3s L140–153
TestCompressionSpeed class class TestCompressionSpeed L161–192
test_zstd_not_slower_than_2x_zlib method method test_zstd_not_slower_than_2x_zlib L162–180
test_zstd_ratio_on_source_code method method test_zstd_ratio_on_source_code L182–192
TestStreamThroughput class class TestStreamThroughput L78–119
test_1000_object_stream_under_2s method method test_1000_object_stream_under_2s L102–119
test_500_object_stream_under_1s method method test_500_object_stream_under_1s L79–100
_DT variable variable _DT L28–28
_init_repo function function _init_repo L35–43
_make_chain function function _make_chain L46–70
_sha function function _sha L31–32
CommitRecord import import CommitRecord L24–24
SnapshotRecord import import SnapshotRecord L24–24
annotations import import annotations L14–14
blob_id import import blob_id L26–26
compute_commit_id import import compute_commit_id L23–23
compute_snapshot_id import import compute_snapshot_id L23–23
datetime import import datetime L16–16
json import import json L17–17
pathlib import import pathlib L18–18
pytest import import pytest L21–21
time import import time L19–19
write_commit import import write_commit L24–24
write_object import import write_object L25–25
write_snapshot import import write_snapshot L24–24
~ tests/test_mpack_stream.py .py 60 symbols removed
TestReaderBasic class class TestReaderBasic L358–412
test_handles_partial_chunks method method test_handles_partial_chunks L368–380
test_multiple_frames_in_one_feed method method test_multiple_frames_in_one_feed L382–394
test_non_dict_frames_are_skipped method method test_non_dict_frames_are_skipped L406–412
test_returns_frame_dicts method method test_returns_frame_dicts L359–366
test_unknown_frame_types_are_yielded method method test_unknown_frame_types_are_yielded L396–404
TestReaderDecompressObject class class TestReaderDecompressObject L420–443
test_decompress_raw method method test_decompress_raw L430–436
test_decompress_zlib method method test_decompress_zlib L421–428
test_delta_raises_without_base method method test_delta_raises_without_base L438–443
TestRoundTrip class class TestRoundTrip L451–536
test_commit_pack_round_trip method method test_commit_pack_round_trip L484–493
test_end_frame_n_objects_matches_actual method method test_end_frame_n_objects_matches_actual L522–536
test_full_push_stream_round_trip method method test_full_push_stream_round_trip L495–520
test_header_round_trip method method test_header_round_trip L452–468
test_object_round_trip_zlib method method test_object_round_trip_zlib L470–482
TestStress class class TestStress L544–564
test_500_object_stream method method test_500_object_stream L545–564
TestWriterCommitPack class class TestWriterCommitPack L265–285
test_commits_and_snapshots_preserved method method test_commits_and_snapshots_preserved L275–285
test_t_field_is_C method method test_t_field_is_C L266–273
TestWriterEnd class class TestWriterEnd L293–305
test_n_objects_and_n_commits_echoed method method test_n_objects_and_n_commits_echoed L300–305
test_t_field_is_E method method test_t_field_is_E L294–298
TestWriterHeader class class TestWriterHeader L40–147
test_domains_field method method test_domains_field L97–107
test_have_list method method test_have_list L109–117
test_is_valid_msgpack method method test_is_valid_msgpack L47–54
test_objects_bytes_advisory method method test_objects_bytes_advisory L119–128
test_op_field method method test_op_field L74–82
test_provenance_agent_id method method test_provenance_agent_id L84–95
test_returns_bytes method method test_returns_bytes L41–45
test_signature_bytes_present method method test_signature_bytes_present L130–138
test_signer_key_empty_when_no_signing method method test_signer_key_empty_when_no_signing L140–147
test_t_field_is_H method method test_t_field_is_H L56–63
test_v_field_is_mpack_version method method test_v_field_is_mpack_version L65–72
TestWriterObjectRaw class class TestWriterObjectRaw L155–257
test_content_is_bytes method method test_content_is_bytes L239–247
test_content_is_smaller_than_raw_for_compressible_data method method test_content_is_smaller_than_raw_for_compressible_data L249–257
test_domain_field method method test_domain_field L217–225
test_enc_is_zlib_or_zstd method method test_enc_is_zlib_or_zstd L194–202
test_force_zlib method method test_force_zlib L204–215
test_id_field_is_sha256_prefixed method method test_id_field_is_sha256_prefixed L173–182
test_path_field method method test_path_field L227–237
test_returns_bytes method method test_returns_bytes L156–161
test_sz_equals_uncompressed_size method method test_sz_equals_uncompressed_size L184–192
test_t_field_is_O method method test_t_field_is_O L163–171
TestWriterResponseFrames class class TestWriterResponseFrames L313–350
test_write_ack_ready method method test_write_ack_ready L342–350
test_write_error_t_msg_code method method test_write_error_t_msg_code L322–328
test_write_progress_t_and_pct method method test_write_progress_t_and_pct L314–320
test_write_result_ok_true method method test_write_result_ok_true L330–340
_sha function function _sha L31–32
annotations import import annotations L20–20
blob_id import import blob_id L28–28
io import import io L22–22
long_id import import long_id L28–28
msgpack import import msgpack L25–25
pytest import import pytest L26–26
zlib import import zlib L23–23
~ tests/test_mpack_transport.py .py 73 symbols removed
TestFetchStreamContentType class class TestFetchStreamContentType L565–580
test_fetch_stream_accept_uses_mpack_content_type method method test_fetch_stream_accept_uses_mpack_content_type L574–580
test_fetch_stream_uses_mpack_content_type method method test_fetch_stream_uses_mpack_content_type L566–572
TestFetchStreamDecompression class class TestFetchStreamDecompression L588–676
_make_fetch_response_with_object method method _make_fetch_response_with_object L589–609
test_fetch_stream_decompresses_zlib_objects method method test_fetch_stream_decompresses_zlib_objects L611–631
test_fetch_stream_decompresses_zstd_objects method method test_fetch_stream_decompresses_zstd_objects L633–657
test_fetch_stream_objects_received_count method method test_fetch_stream_objects_received_count L659–676
TestLocalFileTransportPushStream class class TestLocalFileTransportPushStream L684–876
test_push_stream_method_exists method method test_push_stream_method_exists L685–691
test_push_stream_returns_push_result method method test_push_stream_returns_push_result L860–876
test_push_stream_updates_branch_ref method method test_push_stream_updates_branch_ref L807–858
test_push_stream_writes_commit_to_remote method method test_push_stream_writes_commit_to_remote L693–748
test_push_stream_writes_objects_to_remote method method test_push_stream_writes_objects_to_remote L750–805
TestPushStreamContentType class class TestPushStreamContentType L302–317
test_push_stream_accept_uses_mpack_content_type method method test_push_stream_accept_uses_mpack_content_type L311–317
test_push_stream_uses_mpack_content_type method method test_push_stream_uses_mpack_content_type L303–309
TestPushStreamFrameSequence class class TestPushStreamFrameSequence L453–495
test_e_frame_n_objects_matches_actual method method test_e_frame_n_objects_matches_actual L484–495
test_frame_sequence_h_c_e method method test_frame_sequence_h_c_e L454–464
test_frame_sequence_h_o_c_e_with_objects method method test_frame_sequence_h_o_c_e_with_objects L466–482
TestPushStreamHFrame class class TestPushStreamHFrame L325–369
test_h_frame_branch_matches method method test_h_frame_branch_matches L352–358
test_h_frame_has_op_push method method test_h_frame_has_op_push L344–350
test_h_frame_has_protocol_version method method test_h_frame_has_protocol_version L334–342
test_h_frame_is_first method method test_h_frame_is_first L326–332
test_h_frame_n_objects_advisory_count method method test_h_frame_n_objects_advisory_count L360–369
TestPushStreamOFrames class class TestPushStreamOFrames L377–445
test_multiple_objects_all_have_sz method method test_multiple_objects_all_have_sz L433–445
test_o_frame_content_decompresses_to_original method method test_o_frame_content_decompresses_to_original L404–415
test_o_frame_has_sz_field method method test_o_frame_has_sz_field L378–391
test_o_frame_id_matches_object_id method method test_o_frame_id_matches_object_id L393–402
test_o_frame_uses_best_compression method method test_o_frame_uses_best_compression L417–431
TestPushStreamResponseParsing class class TestPushStreamResponseParsing L503–557
test_error_frame_raises_transport_error method method test_error_frame_raises_transport_error L515–522
test_error_frame_status_code method method test_error_frame_status_code L524–547
test_progress_frame_does_not_raise method method test_progress_frame_does_not_raise L504–513
test_result_frame_ok_returns_push_result method method test_result_frame_ok_returns_push_result L549–557
_MockPushConn class class _MockPushConn L69–111
__init__ method method __init__ L72–76
close method method close L110–111
endheaders method method endheaders L84–85
getresponse method method getresponse L90–108
putheader method method putheader L81–82
putrequest method method putrequest L78–79
send method method send L87–88
_capture_fetch_request function function _capture_fetch_request L244–282
_capture_push_request function function _capture_push_request L149–200
_decode_push_frames function function _decode_push_frames L114–146
_make_repo function function _make_repo L285–294
_make_signing function function _make_signing L50–52
_mock_stream_response function function _mock_stream_response L55–66
_run_push_via_chunked function function _run_push_via_chunked L203–241
BytesIO import import BytesIO L23–23
HttpTransport import import HttpTransport L36–36
LocalFileTransport import import LocalFileTransport L36–36
MPACK_CONTENT_TYPE import import MPACK_CONTENT_TYPE L29–29
MPACK_VERSION import import MPACK_VERSION L29–29
MPackStreamReader import import MPackStreamReader L29–29
MPackStreamWriter import import MPackStreamWriter L29–29
Mapping import import Mapping L18–18
PushResult import import PushResult L36–36
SigningIdentity import import SigningIdentity L36–36
TransportError import import TransportError L36–36
WIRE_CONTENT_TYPE import import WIRE_CONTENT_TYPE L29–29
annotations import import annotations L17–17
blob_id import import blob_id L28–28
json import import json L20–20
long_id import import long_id L28–28
msgpack import import msgpack L25–25
pathlib import import pathlib L21–21
pytest import import pytest L26–26
mock import import unittest.mock L22–22
~ tests/test_presign_upload.py .py 62 symbols removed
TestT14PresignTransport class class TestT14PresignTransport L69–164
_make_transport method method _make_transport L72–74
_mock_presign_response method method _mock_presign_response L76–81
test_presign_objects_empty_list_returns_empty_dict method method test_presign_objects_empty_list_returns_empty_dict L149–157
test_presign_objects_in_musettransport_protocol method method test_presign_objects_in_musettransport_protocol L159–164
test_presign_objects_method_exists method method test_presign_objects_method_exists L83–87
test_presign_objects_posts_to_presign_endpoint method method test_presign_objects_posts_to_presign_endpoint L89–107
test_presign_objects_returns_url_map method method test_presign_objects_returns_url_map L109–121
test_presign_objects_sends_object_ids_in_body method method test_presign_objects_sends_object_ids_in_body L123–147
TestT15LargeObjectPush class class TestT15LargeObjectPush L224–394
_run method method _run L244–272
repo method method repo L231–235
small_only_repo method method small_only_repo L238–242
test_large_object_not_in_push_stream_payload method method test_large_object_not_in_push_stream_payload L274–287
test_presign_not_called_when_all_objects_small method method test_presign_not_called_when_all_objects_small L325–347
test_presign_objects_called_for_large_objects method method test_presign_objects_called_for_large_objects L307–323
test_presigned_put_is_issued_for_large_object method method test_presigned_put_is_issued_for_large_object L349–365
test_presigned_put_sends_raw_content method method test_presigned_put_sends_raw_content L367–384
test_push_stream_still_called_after_presigned_upload method method test_push_stream_still_called_after_presigned_upload L386–394
test_small_object_still_in_push_stream_payload method method test_small_object_still_in_push_stream_payload L289–305
TestT16R2SSLNoTicket class class TestT16R2SSLNoTicket L397–431
test_make_r2_client_has_no_keepalive method method test_make_r2_client_has_no_keepalive L422–431
test_make_r2_client_has_no_ticket_option method method test_make_r2_client_has_no_ticket_option L409–420
TestT17R2ClientPerPut class class TestT17R2ClientPerPut L434–519
test_presigned_put_creates_new_client method method test_presigned_put_creates_new_client L444–467
test_push_stream_creates_client_per_put method method test_push_stream_creates_client_per_put L469–519
TestT18R2NoH2ALPN class class TestT18R2NoH2ALPN L522–541
test_make_r2_client_uses_http1_only method method test_make_r2_client_uses_http1_only L531–541
TestT19CFrameTruncation class class TestT19CFrameTruncation L688–850
_make_commit_dict method method _make_commit_dict L702–731
_make_snapshot_dict method method _make_snapshot_dict L733–743
test_chunked_c_frames_survive_individually method method test_chunked_c_frames_survive_individually L777–817
test_chunked_frames_each_below_size_limit method method test_chunked_frames_each_below_size_limit L819–850
test_truncated_c_frame_produces_max_map_len_error method method test_truncated_c_frame_produces_max_map_len_error L745–775
TestT20ServerMultiCFrame class class TestT20ServerMultiCFrame L857–924
test_multiple_c_frames_accumulate_commits method method test_multiple_c_frames_accumulate_commits L868–891
test_single_c_frame_still_works method method test_single_c_frame_still_works L893–903
test_snapshots_deduplicated_across_chunks method method test_snapshots_deduplicated_across_chunks L905–924
TestT21R2PutRetry class class TestT21R2PutRetry L548–681
test_presigned_put_raises_after_max_attempts method method test_presigned_put_raises_after_max_attempts L626–644
test_presigned_put_retries_on_connect_error method method test_presigned_put_retries_on_connect_error L597–624
test_presigned_put_retries_on_sslv3 method method test_presigned_put_retries_on_sslv3 L558–595
test_presigned_put_uses_fresh_client_per_attempt method method test_presigned_put_uses_fresh_client_per_attempt L646–681
_large function function _large L59–62
_make_object function function _make_object L50–51
_make_push_result function function _make_push_result L41–47
_make_repo_with_objects function function _make_repo_with_objects L171–221
_oid function function _oid L37–38
_small function function _small L54–56
MagicMock import import MagicMock L24–24
ObjectPayload import import ObjectPayload L29–29
PushResult import import PushResult L29–29
annotations import import annotations L18–18
blob_id import import blob_id L30–30
call import import call L24–24
hashlib import import hashlib L20–20
json import import json L21–21
msgpack import import msgpack L26–26
patch import import patch L24–24
pathlib import import pathlib L22–22
pytest import import pytest L27–27
zlib import import zlib L23–23
~ tests/test_transport_no_legacy_pack.py .py 10 symbols removed
TestHttpTransportNoLegacy class class TestHttpTransportNoLegacy L42–55
test_method_absent method method test_method_absent L51–55
TestLocalFileTransportNoLegacy class class TestLocalFileTransportNoLegacy L63–80
test_method_absent method method test_method_absent L76–80
TestMuseTransportNoLegacy class class TestMuseTransportNoLegacy L29–34
test_no_fetch_pack method method test_no_fetch_pack L30–34
TestNoDeadTypedDicts class class TestNoDeadTypedDicts L88–101
test_not_in_module method method test_not_in_module L97–101
annotations import import annotations L19–19
pytest import import pytest L21–21
~ docs/protocol/musewire-performance.md .md 10 symbols added, 6 symbols removed, 7 symbols modified
code@L159 variable variable code@L159 L159–166
Phase 7 — ASGI route tests (T7–T10) 🔴 BLOCKED (Wall 7) section Phase 7 — ASGI route tests (T7–T10) 🔴 BLOCKED (Wall 7) L129–139
Phase 8 — Commit and push both repos ⬜ PENDING section Phase 8 — Commit and push both repos ⬜ PENDING L139–148
Phase 9 — Deploy and verify ⬜ PENDING section Phase 9 — Deploy and verify ⬜ PENDING L148–157
Wall 7 — T7+ ASGI route tests hang (ACTIVE) section Wall 7 — T7+ ASGI route tests hang (ACTIVE) L294–344
code[python]@L323 variable variable code[python]@L323 L323–327
+ code@L165 variable variable code@L165 L165–171
+ Phase 10 — Final verify 🔴 BLOCKED (Wall 9) section Phase 10 — Final verify 🔴 BLOCKED (Wall 9) L147–153
+ Phase 11 — Legacy cleanup + Wall 9 fix ⬜ IN PROGRESS section Phase 11 — Legacy cleanup + Wall 9 fix ⬜ IN PROGRESS L153–163
+ Phase 7 — ASGI route tests (T7–T10) ✅ DONE section Phase 7 — ASGI route tests (T7–T10) ✅ DONE L129–136
+ Phase 8 — Commit and push both repos ✅ DONE section Phase 8 — Commit and push both repos ✅ DONE L136–141
+ Phase 9 — Deploy and verify ✅ DONE (Wall 8 fixed) section Phase 9 — Deploy and verify ✅ DONE (Wall 8 fixed) L141–147
+ Wall 7 — T7+ ASGI route tests hang (FIXED) section Wall 7 — T7+ ASGI route tests hang (FIXED) L339–362
+ Wall 8 — 401 on staging push stream after Content-Type rename (FIXED) section Wall 8 — 401 on staging push stream after Content-Type rename (FIXED) L328–339
+ Wall 9 — invalid frame magic: b'b5ac' after Wall 8 fix (FIXED) section Wall 9 — invalid frame magic: b'b5ac' after Wall 8 fix (FIXED) L298–328
+ code@L301 variable variable code@L301 L301–304
~ muse/core/mpack.py .py 2 symbols added
+ CommitDict import import CommitDict L99–99
+ SnapshotDict import import SnapshotDict L99–99
~ muse/core/transport.py .py 3 symbols removed, 2 symbols modified
_open_chunked_connection function function _open_chunked_connection L450–477
_send_chunked_frame function function _send_chunked_frame L480–493
_send_terminal_chunk function function _send_terminal_chunk L496–505
~ tests/test_transport_http2.py .py 2 symbols added, 2 symbols removed, 1 symbol modified
test_http_url_uses_http1_chunked method method test_http_url_uses_http1_chunked L155–183
test_no_httpx_raises_transport_error_for_https method method test_no_httpx_raises_transport_error_for_https L133–153
+ test_http_url_also_uses_httpx method method test_http_url_also_uses_httpx L151–156
+ test_no_httpx_raises_transport_error method method test_no_httpx_raises_transport_error L133–149
← Older Oldest on task/delete-http1-chunked-path
All commits
Newer → Latest on task/delete-http1-chunked-path

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