tests/test_materialisation_atomicity.py

• _cfg · function · L51-L55 — def _cfg(tmp_path) -> Config
• _service · function · L58-L71 — def _service(cfg, store, frame_id, workspace: Path)
• _resolve · function · L63-L67 — def _resolve(path, must_exist=False)
• _seed · function · L74-L91 — def _seed(cfg, store, root_frame_id, project_id, filename, payload)
• project · function · L95-L107 — def project(tmp_path)
• _counts · function · L110-L118 — def _counts(store, artifact_id, version_id)
• test_the_live_file_never_shares_an_inode_with_a_snapshot · function · L124-L152 — def test_the_live_file_never_shares_an_inode_with_a_snapshot(project)
• test_the_two_snapshots_have_private_inodes · function · L155-L164 — def test_the_two_snapshots_have_private_inodes(project)
• test_materialise_refuses_same_length_snapshot_tamper_before_any_write · function · L167-L189 — def test_materialise_refuses_same_length_snapshot_tamper_before_any_write(project)
• test_materialise_rejects_a_pending_snapshot_name_swap · function · L192-L223 — def test_materialise_rejects_a_pending_snapshot_name_swap(project, monkeypatch)
• swap_pending · function · L201-L213 — def swap_pending(stage, final, *, size_bytes, checksum)
• test_materialise_rejects_a_live_stage_name_swap_before_publication · function · L226-L267 — def test_materialise_rejects_a_live_stage_name_swap_before_publication( project, monkeypatch )
• replace_stage_with_alien · function · L244-L255 — def replace_stage_with_alien(self, staged, destination)
• test_parallel_dispatchers_share_one_materialise_writer · function · L270-L352 — def test_parallel_dispatchers_share_one_materialise_writer(project, monkeypatch)
• pause_first_writer · function · L299-L303 — def pause_first_writer(filename, data)
• run · function · L308-L319 — def run(service, version_id, *, announce=None, finished=None)
• test_delegated_materialise_uses_root_workspace_and_child_provenance · function · L355-L388 — def test_delegated_materialise_uses_root_workspace_and_child_provenance(project)
• test_delegated_upload_also_separates_workspace_from_producer · function · L391-L418 — def test_delegated_upload_also_separates_workspace_from_producer(tmp_path)
• test_materialise_crash_journal_recovers_and_allows_retry · function · L421-L496 — def test_materialise_crash_journal_recovers_and_allows_retry(project)
• test_a_same_session_materialise_leaves_the_existing_live_file_intact · function · L502-L522 — def test_a_same_session_materialise_leaves_the_existing_live_file_intact(project)
• test_a_successful_materialise_does_not_silently_destroy_a_same_name_file · function · L525-L539 — def test_a_successful_materialise_does_not_silently_destroy_a_same_name_file(project)
• test_a_same_name_materialise_can_be_asked_for_explicitly · function · L542-L554 — def test_a_same_name_materialise_can_be_asked_for_explicitly(project)
• test_a_failed_db_commit_restores_the_previous_live_file · function · L557-L589 — def test_a_failed_db_commit_restores_the_previous_live_file(project, monkeypatch)
• explode · function · L570-L571 — def explode(**kwargs)
• test_a_colliding_name_is_refused_before_anything_is_written · function · L592-L612 — def test_a_colliding_name_is_refused_before_anything_is_written(project)
• test_no_staged_part_file_survives_a_failure · function · L615-L632 — def test_no_staged_part_file_survives_a_failure(project, monkeypatch)
• _Hub · class · L638-L649 — class _Hub
• init · method · L639-L640 — def init(self) -> None
• emitter · method · L642-L646 — def emitter(self, root_frame_id: str)
• emit · function · L643-L644 — def emit(event: dict) -> None
• broadcast · method · L648-L649 — def broadcast(self, root_frame_id: str, event: dict) -> None
• _runner · function · L652-L661 — def _runner(cfg)
• test_a_rejected_upload_does_not_truncate_the_previous_live_file · function · L664-L713 — def test_a_rejected_upload_does_not_truncate_the_previous_live_file(tmp_path)
• test_a_committed_upload_version_always_has_frozen_bytes · function · L716-L743 — def test_a_committed_upload_version_always_has_frozen_bytes(tmp_path)
• test_a_rejected_upload_writes_nothing_to_disk_at_all · function · L746-L784 — def test_a_rejected_upload_writes_nothing_to_disk_at_all(tmp_path, monkeypatch)
• spy · function · L766-L768 — def spy(self, data)
• test_an_in_cell_materialise_makes_one_version_not_two · function · L787-L840 — def test_an_in_cell_materialise_makes_one_version_not_two(project)
• test_the_worker_gives_a_materialise_the_cell_identity_to_dedup_with · function · L843-L871 — def test_the_worker_gives_a_materialise_the_cell_identity_to_dedup_with()