gabriel / musehub public
refactor BREAKING dev
AI Agent gabriel · 112 days ago · May 20, 2026 · Diff

refactor: decompose musehub_wire.py into shared/push/fetch modules, remove mpack.index dead code

sha256:bbe09c027ffec9050e82185e6e7485ac5ab75db348297a440aef3c8ed2226637 sha
sha256:a4e3fddaad9de194d486c79763f9e84f7b1b372364c4d31d11109cf2911ef9e1 parent
+248 ~1 −113 symbols
sha256:634de6a0492f105f3ded8f182d5479cbe9e9b2955dc2156ab963b0c30ad2203f snapshot
+248
symbols added
~1
symbol modified
−113
symbols removed
0
dead code introduced
Semantic Changes 362 symbols
~ musehub/services/musehub_wire_fetch.py .py 43 symbols added
+ FetchCommitNotFound class class FetchCommitNotFound L804–805 ← moved from musehub/services/musehub_wire.py
+ FetchNotReady class class FetchNotReady L808–809 ← moved from musehub/services/musehub_wire.py
+ FetchResult class class FetchResult L797–801 ← moved from musehub/services/musehub_wire.py
+ MPackGCResult class class MPackGCResult L683–687
+ _check_missing_objects function async_function _check_missing_objects L665–680
+ _walk_commit_delta function async_function _walk_commit_delta L42–171
+ AsyncSession import import AsyncSession L13–13
+ FetchMPackResult import import FetchMPackResult L29–29
+ FetchNotIndexedError import import FetchNotIndexedError L29–29
+ FetchPresignResult import import FetchPresignResult L29–29
+ MPackValidationError import import MPackValidationError L29–29
+ MusehubBranch import import MusehubBranch L15–15
+ MusehubCommit import import MusehubCommit L15–15
+ MusehubCommitGraph import import MusehubCommitGraph L15–15
+ MusehubMPackIndex import import MusehubMPackIndex L15–15
+ MusehubObject import import MusehubObject L15–15
+ MusehubObjectRef import import MusehubObjectRef L15–15
+ MusehubRepo import import MusehubRepo L15–15
+ MusehubSnapshot import import MusehubSnapshot L15–15
+ TypedDict import import TypedDict L9–9
+ WireFetchRequest import import WireFetchRequest L25–25
+ _msgpack import import _msgpack L6–6
+ _pg_insert import import _pg_insert L12–12
+ _reconstruct_manifest import import _reconstruct_manifest L29–29
+ _sa_text import import _sa_text L11–11
+ _snap_row_to_wire import import _snap_row_to_wire L29–29
+ _time_module import import _time_module L7–7
+ _to_wire_commit import import _to_wire_commit L29–29
+ _utc_now import import _utc_now L29–29
+ asyncio import import asyncio L3–3
+ blob_id import import blob_id L26–26
+ datetime import import datetime L8–8
+ func function import func L11–11
+ get_backend import import get_backend L27–27
+ hashlib import import hashlib L4–4
+ logger import import logger L29–29
+ logging import import logging L5–5
+ select import import select L11–11
+ timezone import import timezone L8–8
+ process_mpack_gc_job function async_function process_mpack_gc_job L690–794
+ wire_fetch function async_function wire_fetch L812–933
+ wire_fetch_mpack function async_function wire_fetch_mpack L324–663
+ wire_fetch_presign function async_function wire_fetch_presign L174–322
~ musehub/services/musehub_wire_push.py .py 68 symbols added
+ _COMMIT_BATCH variable variable _COMMIT_BATCH L57–57 ← moved from musehub/services/musehub_wire.py
+ _EMPTY_OID variable variable _EMPTY_OID L56–56 ← moved from musehub/services/musehub_wire.py
+ _ObjFetchMap variable variable _ObjFetchMap L232–232 ← moved from musehub/services/musehub_wire.py
+ _fetch_commit function async_function _fetch_commit L226–230
+ _fetch_object_meta function async_function _fetch_object_meta L234–251
+ _topological_sort function function _topological_sort L253–283
+ check_push_anomaly function async_function check_push_anomaly L302–342
+ AsyncSession import import AsyncSession L13–13
+ IntDict import import IntDict L32–32
+ JSONObject import import JSONObject L32–32
+ JSONValue import import JSONValue L32–32
+ MPackValidationError import import MPackValidationError L37–37
+ MusehubBlockedHash import import MusehubBlockedHash L15–15
+ MusehubBranch import import MusehubBranch L17–17
+ MusehubCollaborator import import MusehubCollaborator L16–16
+ MusehubCommit import import MusehubCommit L17–17
+ MusehubCommitGraph import import MusehubCommitGraph L17–17
+ MusehubCommitRef import import MusehubCommitRef L17–17
+ MusehubDailyPushBytes import import MusehubDailyPushBytes L15–15
+ MusehubMPackIndex import import MusehubMPackIndex L17–17
+ MusehubObject import import MusehubObject L17–17
+ MusehubObjectRef import import MusehubObjectRef L17–17
+ MusehubPushAnomaly import import MusehubPushAnomaly L15–15
+ MusehubRepo import import MusehubRepo L17–17
+ MusehubSnapshot import import MusehubSnapshot L17–17
+ MusehubSnapshotRef import import MusehubSnapshotRef L17–17
+ NonFastForwardError import import NonFastForwardError L37–37
+ ObjectHashMismatch import import ObjectHashMismatch L37–37
+ RepairResult import import RepairResult L37–37
+ StrDict import import StrDict L32–32
+ WireCommit import import WireCommit L29–29
+ WireRefsResponse import import WireRefsResponse L29–29
+ _ChildMap import import _ChildMap L37–37
+ _int_safe import import _int_safe L37–37
+ _is_fast_forward import import _is_fast_forward L37–37
+ _msgpack import import _msgpack L7–7
+ _parse_iso import import _parse_iso L37–37
+ _pg_insert import import _pg_insert L12–12
+ _reconstruct_manifest import import _reconstruct_manifest L37–37
+ _sa_text import import _sa_text L11–11
+ _snap_row_to_wire import import _snap_row_to_wire L37–37
+ _str_list import import _str_list L37–37
+ _time_module import import _time_module L8–8
+ _to_wire_commit import import _to_wire_commit L37–37
+ _upsert_object_refs import import _upsert_object_refs L37–37
+ _utc_now import import _utc_now L37–37
+ asyncio import import asyncio L3–3
+ blob_id import import blob_id L30–30
+ collections import import collections L4–4
+ compute_branch_id import import compute_branch_id L31–31
+ datetime import import datetime L9–9
+ func function import func L11–11
+ get_backend import import get_backend L34–34
+ hashlib import import hashlib L5–5
+ logger import import logger L37–37
+ logging import import logging L6–6
+ read_object_bytes import import read_object_bytes L35–35
+ select import import select L11–11
+ settings import import settings L33–33
+ split_id import import split_id L30–30
+ timezone import import timezone L9–9
+ record_mpack_bytes_uploaded function async_function record_mpack_bytes_uploaded L285–299
+ wire_fetch_objects function async_function wire_fetch_objects L152–166
+ wire_push_mpack_presign function async_function wire_push_mpack_presign L345–355
+ wire_push_unpack_mpack function async_function wire_push_unpack_mpack L358–883
+ wire_refs function async_function wire_refs L60–100
+ wire_repair_object function async_function wire_repair_object L102–150
+ wire_repair_snapshot function async_function wire_repair_snapshot L168–224
~ musehub/services/musehub_wire_shared.py .py 89 symbols added
+ FetchMPackResult class class FetchMPackResult L79–83
+ FetchNotIndexedError class class FetchNotIndexedError L85–88
+ __init__ method method __init__ L86–88 ← moved from musehub/services/musehub_wire.py
+ FetchPresignResult class class FetchPresignResult L66–77
+ MPackValidationError class class MPackValidationError L174–175
+ NonFastForwardError class class NonFastForwardError L180–181
+ ObjectHashMismatch class class ObjectHashMismatch L177–178
+ PolyglotObjectError class class PolyglotObjectError L244–247
+ __init__ method method __init__ L245–247 ← moved from musehub/services/musehub_wire.py
+ RepairResult class class RepairResult L63–64
+ _BLOB_PUT_SEM variable variable _BLOB_PUT_SEM L11–11 ← moved from musehub/services/musehub_wire.py
+ _BytesMap variable variable _BytesMap L92–92 ← moved from musehub/services/musehub_wire.py
+ _ChildMap variable variable _ChildMap L93–93 ← moved from musehub/services/musehub_wire.py
+ _ObjFetchMap variable variable _ObjFetchMap L90–90
+ _ObjectMap variable variable _ObjectMap L91–91 ← moved from musehub/services/musehub_wire.py
+ _commit_identity_bytes function function _commit_identity_bytes L97–110
+ _get_blob_put_sem function function _get_blob_put_sem L13–17
+ _int_safe function function _int_safe L283–284
+ _is_ancestor_db function async_function _is_ancestor_db L221–241
+ _is_fast_forward function function _is_fast_forward L184–218
+ _monotonic variable variable _monotonic L61–61 ← moved from musehub/services/musehub_wire.py
+ _parse_iso function function _parse_iso L267–271
+ _reconstruct_manifest function async_function _reconstruct_manifest L113–155
+ _snap_row_to_wire function function _snap_row_to_wire L313–333
+ _str_list function function _str_list L278–281
+ _str_values function function _str_values L273–276
+ _to_wire_commit function function _to_wire_commit L286–311
+ _upsert_object_refs function async_function _upsert_object_refs L158–172
+ _utc_now function function _utc_now L264–265 ← moved from musehub/services/musehub_wire.py
+ _verify_object_hash function function _verify_object_hash L249–262
+ AsyncIterator import import AsyncIterator L58–58 ← moved from musehub/services/musehub_wire.py
+ AsyncSession import import AsyncSession L21–21 ← moved from musehub/services/musehub_wire.py
+ IntDict import import IntDict L52–52
+ JSONObject import import JSONObject L52–52
+ JSONValue import import JSONValue L52–52
+ MusehubBackgroundJob import import MusehubBackgroundJob L25–25 ← moved from musehub/services/musehub_wire.py
+ MusehubBlockedHash import import MusehubBlockedHash L23–23
+ MusehubBranch import import MusehubBranch L26–26
+ MusehubCollaborator import import MusehubCollaborator L24–24 ← moved from musehub/services/musehub_wire.py
+ MusehubCommit import import MusehubCommit L26–26
+ MusehubCommitGraph import import MusehubCommitGraph L26–26
+ MusehubCommitRef import import MusehubCommitRef L26–26
+ MusehubDailyPushBytes import import MusehubDailyPushBytes L23–23
+ MusehubMPackIndex import import MusehubMPackIndex L26–26
+ MusehubObject import import MusehubObject L26–26
+ MusehubObjectRef import import MusehubObjectRef L26–26
+ MusehubPackIndex import import MusehubPackIndex L26–26
+ MusehubPushAnomaly import import MusehubPushAnomaly L23–23 ← moved from musehub/services/musehub_wire.py
+ MusehubRepo import import MusehubRepo L26–26
+ MusehubSnapshot import import MusehubSnapshot L26–26
+ MusehubSnapshotRef import import MusehubSnapshotRef L26–26 ← moved from musehub/services/musehub_wire.py
+ PydanticJson import import PydanticJson L53–53
+ StrDict import import StrDict L52–52 ← moved from musehub/services/musehub_wire.py
+ TypedDict import import TypedDict L59–59 ← moved from musehub/services/musehub_wire.py
+ WireCommit import import WireCommit L39–39
+ WireFetchRequest import import WireFetchRequest L39–39
+ WireMPack import import WireMPack L39–39
+ WireObject import import WireObject L39–39
+ WireRefsResponse import import WireRefsResponse L39–39
+ WireSnapshot import import WireSnapshot L39–39 ← moved from musehub/services/musehub_wire.py
+ ZSTD_AVAILABLE import import ZSTD_AVAILABLE L50–50
+ _msgpack import import _msgpack L7–7 ← moved from musehub/services/musehub_wire.py
+ _muse_commit_identity_bytes import import _muse_commit_identity_bytes L48–48 ← moved from musehub/services/musehub_wire.py
+ _pg_insert import import _pg_insert L20–20 ← moved from musehub/services/musehub_wire.py
+ _sa_text import import _sa_text L19–19
+ _time_module import import _time_module L8–8 ← moved from musehub/services/musehub_wire.py
+ asyncio import import asyncio L3–3 ← moved from musehub/services/musehub_wire.py
+ blob_id import import blob_id L47–47
+ collections import import collections L4–4 ← moved from musehub/services/musehub_wire.py
+ compress_and_encode import import compress_and_encode L50–50
+ compute_branch_id import import compute_branch_id L51–51 ← moved from musehub/services/musehub_wire.py
+ compute_delta import import compute_delta L50–50 ← moved from musehub/services/musehub_wire.py
+ datetime import import datetime L9–9
+ decode_pubkey import import decode_pubkey L47–47
+ enqueue_profile_snapshot import import enqueue_profile_snapshot L57–57
+ enqueue_push_intel import import enqueue_push_intel L57–57 ← moved from musehub/services/musehub_wire.py
+ func function import func L19–19
+ get_backend import import get_backend L55–55 ← moved from musehub/services/musehub_wire.py
+ hashlib import import hashlib L5–5 ← moved from musehub/services/musehub_wire.py
+ logging import import logging L6–6 ← moved from musehub/services/musehub_wire.py
+ provenance_payload import import provenance_payload L49–49
+ read_object_bytes import import read_object_bytes L56–56 ← moved from musehub/services/musehub_wire.py
+ select import import select L19–19 ← moved from musehub/services/musehub_wire.py
+ settings import import settings L54–54 ← moved from musehub/services/musehub_wire.py
+ split_id import import split_id L47–47 ← moved from musehub/services/musehub_wire.py
+ timezone import import timezone L9–9 ← moved from musehub/services/musehub_wire.py
+ unwrap import import unwrap L53–53 ← moved from musehub/services/musehub_wire.py
+ verify_commit_ed25519 import import verify_commit_ed25519 L49–49 ← moved from musehub/services/musehub_wire.py
+ logger variable variable logger L95–95 ← moved from musehub/services/musehub_wire.py
~ musehub/services/musehub_wire.py .py 48 symbols added, 113 symbols removed
− FetchCommitNotFound class class FetchCommitNotFound L2866–2867 → moved to musehub/services/musehub_wire_fetch.py
− FetchMPackResult class class FetchMPackResult L115–126
− FetchNotIndexedError class class FetchNotIndexedError L128–136
− __init__ method method __init__ L134–136 → moved to musehub/services/musehub_wire_shared.py
− FetchNotReady class class FetchNotReady L2870–2871 → moved to musehub/services/musehub_wire_fetch.py
− FetchPresignResult class class FetchPresignResult L100–113
− FetchResult class class FetchResult L2716–2720 → moved to musehub/services/musehub_wire_fetch.py
− MPackGCResult class class MPackGCResult L2576–2582
− MPackValidationError class class MPackValidationError L258–264
− NonFastForwardError class class NonFastForwardError L269–270
− ObjectHashMismatch class class ObjectHashMismatch L266–267
− PolyglotObjectError class class PolyglotObjectError L347–357
− __init__ method method __init__ L355–357 → moved to musehub/services/musehub_wire_shared.py
− RepairResult class class RepairResult L95–98
− _BLOB_PUT_SEM variable variable _BLOB_PUT_SEM L37–37 → moved to musehub/services/musehub_wire_shared.py
− _BytesMap variable variable _BytesMap L143–143 → moved to musehub/services/musehub_wire_shared.py
− _COMMIT_BATCH variable variable _COMMIT_BATCH L677–677 → moved to musehub/services/musehub_wire_push.py
− _ChildMap variable variable _ChildMap L144–144 → moved to musehub/services/musehub_wire_shared.py
− _EMPTY_OID variable variable _EMPTY_OID L674–674 → moved to musehub/services/musehub_wire_push.py
− _ObjFetchMap variable variable _ObjFetchMap L673–673 → moved to musehub/services/musehub_wire_push.py
− _ObjectMap variable variable _ObjectMap L142–142 → moved to musehub/services/musehub_wire_shared.py
− _check_missing_objects function async_function _check_missing_objects L2552–2573
− _commit_identity_bytes function function _commit_identity_bytes L148–162
− _fetch_commit function async_function _fetch_commit L666–671
− _fetch_object_meta function async_function _fetch_object_meta L679–697
− _get_blob_put_sem function function _get_blob_put_sem L39–48
− _int_safe function function _int_safe L403–405
− _is_ancestor_db function async_function _is_ancestor_db L319–344
− _is_fast_forward function function _is_fast_forward L273–316
− _monotonic variable variable _monotonic L93–93 → moved to musehub/services/musehub_wire_shared.py
− _parse_iso function function _parse_iso L384–389
− _reconstruct_manifest function async_function _reconstruct_manifest L165–217
− _snap_row_to_wire function function _snap_row_to_wire L435–456
− _str_list function function _str_list L397–401
− _str_values function function _str_values L391–395
− _to_wire_commit function function _to_wire_commit L407–433
− _topological_sort function function _topological_sort L699–733
− _upsert_object_refs function async_function _upsert_object_refs L220–256
− _utc_now function function _utc_now L381–382 → moved to musehub/services/musehub_wire_shared.py
− _verify_object_hash function function _verify_object_hash L359–377
− _walk_commit_delta function async_function _walk_commit_delta L1807–1947
− check_push_anomaly function async_function check_push_anomaly L758–804
− AsyncIterator import import AsyncIterator L89–89 → moved to musehub/services/musehub_wire_shared.py
− AsyncSession import import AsyncSession L52–52 → moved to musehub/services/musehub_wire_shared.py
− IntDict import import IntDict L83–83
− JSONObject import import JSONObject L83–83
− JSONValue import import JSONValue L83–83
− MusehubBackgroundJob import import MusehubBackgroundJob L56–56 → moved to musehub/services/musehub_wire_shared.py
− MusehubBlockedHash import import MusehubBlockedHash L54–54
− MusehubBranch import import MusehubBranch L57–57
− MusehubCollaborator import import MusehubCollaborator L55–55 → moved to musehub/services/musehub_wire_shared.py
− MusehubCommit import import MusehubCommit L57–57
− MusehubCommitGraph import import MusehubCommitGraph L57–57
− MusehubCommitRef import import MusehubCommitRef L57–57
− MusehubDailyPushBytes import import MusehubDailyPushBytes L54–54
− MusehubMPackIndex import import MusehubMPackIndex L57–57
− MusehubObject import import MusehubObject L57–57
− MusehubObjectRef import import MusehubObjectRef L57–57
− MusehubPackIndex import import MusehubPackIndex L57–57
− MusehubPushAnomaly import import MusehubPushAnomaly L54–54 → moved to musehub/services/musehub_wire_shared.py
− MusehubRepo import import MusehubRepo L57–57
− MusehubSnapshot import import MusehubSnapshot L57–57
− MusehubSnapshotRef import import MusehubSnapshotRef L57–57 → moved to musehub/services/musehub_wire_shared.py
− PydanticJson import import PydanticJson L84–84
− StrDict import import StrDict L83–83 → moved to musehub/services/musehub_wire_shared.py
− TypedDict import import TypedDict L90–90 → moved to musehub/services/musehub_wire_shared.py
− WireCommit import import WireCommit L70–70
− WireFetchRequest import import WireFetchRequest L70–70
− WireMPack import import WireMPack L70–70
− WireObject import import WireObject L70–70
− WireRefsResponse import import WireRefsResponse L70–70
− WireSnapshot import import WireSnapshot L70–70 → moved to musehub/services/musehub_wire_shared.py
− ZSTD_AVAILABLE import import ZSTD_AVAILABLE L81–81
− _msgpack import import _msgpack L23–23 → moved to musehub/services/musehub_wire_shared.py
− _muse_commit_identity_bytes import import _muse_commit_identity_bytes L79–79 → moved to musehub/services/musehub_wire_shared.py
− _pg_insert import import _pg_insert L51–51 → moved to musehub/services/musehub_wire_shared.py
− _sa_text import import _sa_text L50–50
− _time_module import import _time_module L24–24 → moved to musehub/services/musehub_wire_shared.py
− asyncio import import asyncio L19–19 → moved to musehub/services/musehub_wire_shared.py
− blob_id import import blob_id L78–78
− collections import import collections L20–20 → moved to musehub/services/musehub_wire_shared.py
− compress_and_encode import import compress_and_encode L81–81
− compute_branch_id import import compute_branch_id L82–82 → moved to musehub/services/musehub_wire_shared.py
− compute_delta import import compute_delta L81–81 → moved to musehub/services/musehub_wire_shared.py
− datetime import import datetime L25–25
− decode_pubkey import import decode_pubkey L78–78
− enqueue_profile_snapshot import import enqueue_profile_snapshot L88–88
− enqueue_push_intel import import enqueue_push_intel L88–88 → moved to musehub/services/musehub_wire_shared.py
− func function import func L50–50
− get_backend import import get_backend L86–86 → moved to musehub/services/musehub_wire_shared.py
− hashlib import import hashlib L21–21 → moved to musehub/services/musehub_wire_shared.py
− logging import import logging L22–22 → moved to musehub/services/musehub_wire_shared.py
− provenance_payload import import provenance_payload L80–80
− read_object_bytes import import read_object_bytes L87–87 → moved to musehub/services/musehub_wire_shared.py
− select import import select L50–50 → moved to musehub/services/musehub_wire_shared.py
− settings import import settings L85–85 → moved to musehub/services/musehub_wire_shared.py
− split_id import import split_id L78–78 → moved to musehub/services/musehub_wire_shared.py
− timezone import import timezone L25–25 → moved to musehub/services/musehub_wire_shared.py
− unwrap import import unwrap L84–84 → moved to musehub/services/musehub_wire_shared.py
− verify_commit_ed25519 import import verify_commit_ed25519 L80–80 → moved to musehub/services/musehub_wire_shared.py
− logger variable variable logger L146–146 → moved to musehub/services/musehub_wire_shared.py
− process_mpack_gc_job function async_function process_mpack_gc_job L2585–2711
− process_mpack_index_job function async_function process_mpack_index_job L1391–1804
− record_mpack_bytes_uploaded function async_function record_mpack_bytes_uploaded L735–755
− wire_fetch function async_function wire_fetch L2723–2863
− wire_fetch_mpack function async_function wire_fetch_mpack L2154–2550
− wire_fetch_objects function async_function wire_fetch_objects L572–591
− wire_fetch_presign function async_function wire_fetch_presign L1950–2152
− wire_push_mpack_presign function async_function wire_push_mpack_presign L807–825
− wire_push_unpack_mpack function async_function wire_push_unpack_mpack L828–1388
− wire_refs function async_function wire_refs L460–504
− wire_repair_object function async_function wire_repair_object L506–570
− wire_repair_snapshot function async_function wire_repair_snapshot L593–664
+ FetchCommitNotFound import import FetchCommitNotFound L52–52
+ FetchMPackResult import import FetchMPackResult L8–8
+ FetchNotIndexedError import import FetchNotIndexedError L8–8
+ FetchNotReady import import FetchNotReady L52–52
+ FetchPresignResult import import FetchPresignResult L8–8
+ FetchResult import import FetchResult L52–52
+ MPackGCResult import import MPackGCResult L52–52
+ MPackValidationError import import MPackValidationError L8–8
+ NonFastForwardError import import NonFastForwardError L8–8
+ ObjectHashMismatch import import ObjectHashMismatch L8–8
+ PolyglotObjectError import import PolyglotObjectError L8–8
+ RepairResult import import RepairResult L8–8
+ _COMMIT_BATCH import import _COMMIT_BATCH L35–35
+ _EMPTY_OID import import _EMPTY_OID L35–35
+ _ObjFetchMap import import _ObjFetchMap L35–35
+ _check_missing_objects import import _check_missing_objects L52–52
+ _commit_identity_bytes import import _commit_identity_bytes L8–8
+ _fetch_commit import import _fetch_commit L35–35
+ _fetch_object_meta import import _fetch_object_meta L35–35
+ _get_blob_put_sem import import _get_blob_put_sem L8–8
+ _int_safe import import _int_safe L8–8
+ _is_ancestor_db import import _is_ancestor_db L8–8
+ _is_fast_forward import import _is_fast_forward L8–8
+ _monotonic import import _monotonic L8–8
+ _parse_iso import import _parse_iso L8–8
+ _reconstruct_manifest import import _reconstruct_manifest L8–8
+ _snap_row_to_wire import import _snap_row_to_wire L8–8
+ _str_list import import _str_list L8–8
+ _str_values import import _str_values L8–8
+ _to_wire_commit import import _to_wire_commit L8–8
+ _topological_sort import import _topological_sort L35–35
+ _upsert_object_refs import import _upsert_object_refs L8–8
+ _utc_now import import _utc_now L8–8
+ _verify_object_hash import import _verify_object_hash L8–8
+ _walk_commit_delta import import _walk_commit_delta L52–52
+ check_push_anomaly import import check_push_anomaly L35–35
+ logger import import logger L8–8
+ process_mpack_gc_job import import process_mpack_gc_job L52–52
+ record_mpack_bytes_uploaded import import record_mpack_bytes_uploaded L35–35
+ wire_fetch import import wire_fetch L52–52
+ wire_fetch_mpack import import wire_fetch_mpack L52–52
+ wire_fetch_objects import import wire_fetch_objects L35–35
+ wire_fetch_presign import import wire_fetch_presign L52–52
+ wire_push_mpack_presign import import wire_push_mpack_presign L35–35
+ wire_push_unpack_mpack import import wire_push_unpack_mpack L35–35
+ wire_refs import import wire_refs L35–35
+ wire_repair_object import import wire_repair_object L35–35
+ wire_repair_snapshot import import wire_repair_snapshot L35–35
~ musehub/worker.py .py 1 symbol modified
~ _process_one
← Older Oldest on dev
All commits
Newer → Latest on dev

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