tests/test_compute_harvest_safety.py

• cfg · function · L36-L43 — def cfg(tmp_path)
• _manager · function · L46-L47 — def _manager(cfg, workspace)
• _ProbeProc · class · L50-L69 — class _ProbeProc
• init · method · L59-L63 — def init(self, returncode=0, stdout=b"", stderr=b"")
• wait · method · L65-L66 — def wait(self, timeout=None)
• kill · method · L68-L69 — def kill(self)
• test_a_symlinked_hpc_root_is_refused · function · L77-L92 — def test_a_symlinked_hpc_root_is_refused(cfg, tmp_path)
• test_a_symlinked_per_job_dir_is_refused · function · L95-L105 — def test_a_symlinked_per_job_dir_is_refused(cfg, tmp_path)
• test_a_legitimate_harvest_dir_is_allowed_and_contained · function · L108-L113 — def test_a_legitimate_harvest_dir_is_allowed_and_contained(cfg, tmp_path)
• test_publish_refuses_a_symlinked_hpc_root_swapped_after_validation · function · L116-L138 — def test_publish_refuses_a_symlinked_hpc_root_swapped_after_validation(cfg, tmp_path)
• test_publish_replaces_a_symlinked_per_job_entry_without_following_it · function · L141-L159 — def test_publish_replaces_a_symlinked_per_job_entry_without_following_it(cfg, tmp_path)
• test_rmtree_at_is_anchored_to_the_fd_not_the_pathname · function · L162-L190 — def test_rmtree_at_is_anchored_to_the_fd_not_the_pathname(tmp_path)
• test_a_failed_reharvest_does_not_destroy_previously_published_outputs · function · L193-L246 — def test_a_failed_reharvest_does_not_destroy_previously_published_outputs( cfg, tmp_path )
• probe_says_exit_zero · function · L216-L217 — def probe_says_exit_zero(argv, a, *k)
• good_harvest · function · L225-L227 — def good_harvest(alias, workdir, staging, exclude)
• failed_harvest · function · L235-L236 — def failed_harvest(alias, workdir, staging, exclude)
• test_a_failed_harvest_does_not_leak_its_staging_directory · function · L249-L290 — def test_a_failed_harvest_does_not_leak_its_staging_directory(cfg, tmp_path)
• failing_harvest · function · L268-L271 — def failing_harvest(alias, workdir, staging, exclude): # Extraction got part-way, then the transfer failed.
• probe_says_exit_zero · function · L277-L278 — def probe_says_exit_zero(argv, a, *k)
• test_a_terminal_job_repolled_returns_stored_evidence_not_a_reharvest · function · L293-L359 — def test_a_terminal_job_repolled_returns_stored_evidence_not_a_reharvest(cfg, tmp_path)
• probe_says_exit_zero · function · L320-L321 — def probe_says_exit_zero(argv, a, *k)
• good_harvest · function · L329-L331 — def good_harvest(alias, workdir, staging, exclude)
• tampered_harvest · function · L342-L344 — def tampered_harvest(alias, workdir, staging, exclude)
• _CatStub · class · L362-L374 — class _CatStub
• init · method · L365-L368 — def init(self, payload: bytes)
• wait · method · L370-L371 — def wait(self, timeout=None)
• kill · method · L373-L374 — def kill(self)
• _StallCatStub · class · L377-L398 — class _StallCatStub
• init · method · L382-L389 — def init(self, prefix: bytes = b"partial-then-stall")
• wait · method · L391-L392 — def wait(self, timeout=None)
• kill · method · L394-L398 — def kill(self)
• test_the_capped_transfer_times_out_on_a_stalled_stream · function · L401-L422 — def test_the_capped_transfer_times_out_on_a_stalled_stream(cfg, tmp_path, monkeypatch)
• test_the_capped_transfer_aborts_on_the_actual_bytes_not_the_ack · function · L425-L445 — def test_the_capped_transfer_aborts_on_the_actual_bytes_not_the_ack( cfg, tmp_path, monkeypatch )
• test_the_capped_transfer_delivers_a_within_cap_archive · function · L448-L460 — def test_the_capped_transfer_delivers_a_within_cap_archive(cfg, tmp_path, monkeypatch)
• _byoc_manager · function · L468-L482 — def _byoc_manager(cfg, workspace, job_id="job-byoc")
• _tgz_with · function · L485-L494 — def _tgz_with(files: dict[str, bytes]) -> bytes
• test_a_terminal_byoc_job_repolled_returns_stored_evidence · function · L497-L533 — def test_a_terminal_byoc_job_repolled_returns_stored_evidence(cfg, tmp_path)
• helper · function · L504-L506 — def helper(prov, verb, payload, creds, stage, a, *k)
• counting_helper · function · L518-L520 — def counting_helper(prov, verb, payload, creds, stage, a, *k)
• test_a_hostile_byoc_archive_leaves_no_staging_directory · function · L536-L562 — def test_a_hostile_byoc_archive_leaves_no_staging_directory(cfg, tmp_path)
• helper · function · L551-L553 — def helper(prov, verb, payload, creds, stage, a, *k)
• _ChattyCatStub · class · L565-L597 — class _ChattyCatStub
• init · method · L573-L590 — def init(self, payload: bytes, noise: bytes)
• _spew · function · L580-L587 — def _spew()
• wait · method · L592-L594 — def wait(self, timeout=None)
• kill · method · L596-L597 — def kill(self)
• test_the_capped_transfer_bounds_the_stderr_it_retains · function · L600-L630 — def test_the_capped_transfer_bounds_the_stderr_it_retains(cfg, tmp_path, monkeypatch)
• test_the_staging_dir_is_host_owned_and_outside_the_workspace · function · L633-L640 — def test_the_staging_dir_is_host_owned_and_outside_the_workspace(cfg, tmp_path)
• test_a_planted_output_is_not_counted_as_produced · function · L643-L695 — def test_a_planted_output_is_not_counted_as_produced(cfg, tmp_path)
• fake_harvest_ssh · function · L668-L669 — def fake_harvest_ssh(alias, workdir, staging, exclude)
• probe_says_exit_zero · function · L673-L674 — def probe_says_exit_zero(argv, a, *k)
• test_enforce_refuses_to_run_the_helper_unconfined · function · L703-L731 — def test_enforce_refuses_to_run_the_helper_unconfined(cfg, tmp_path, monkeypatch)
• refuse · function · L712-L713 — def refuse(_a, *_k)
• test_auto_still_degrades_visibly · function · L734-L766 — def test_auto_still_degrades_visibly(cfg, tmp_path, monkeypatch)
• fake_spawn · function · L752-L755 — def fake_spawn(argv, creds, env, deadline, op, st)
• test_a_declaration_of_only_hidden_outputs_features_nothing · function · L774-L785 — def test_a_declaration_of_only_hidden_outputs_features_nothing()
• test_omitting_outputs_still_features_everything · function · L788-L791 — def test_omitting_outputs_still_features_everything()