tests/test_compute_lifecycle.py

cfg · function · L40-L50 — def cfg(tmp_path)
byoc · function · L54-L61 — def byoc(cfg, tmp_path)
_Proc · class · L64-L83 — class _Proc
init · method · L73-L77 — def init(self, returncode=0, stdout=b"", stderr=b"")
wait · method · L79-L80 — def wait(self, timeout=None)
kill · method · L82-L83 — def kill(self)
_Stdin · class · L91-L98 — class _Stdin
write · method · L94-L95 — def write(self, _data)
close · method · L97-L98 — def close(self)
_fake_popen · function · L101-L129 — def _fake_popen(behaviour)
_Helper · class · L111-L127 — class _Helper
init · method · L112-L120 — def init(self, argv, **_kw)
wait · method · L122-L124 — def wait(self, timeout=None)
kill · method · L126-L127 — def kill(self)
_reply · function · L132-L135 — def _reply(stage: Path, payload: dict) -> None
test_a_helper_that_died_before_replying_is_unknown_not_failed · function · L138-L166 — def test_a_helper_that_died_before_replying_is_unknown_not_failed( byoc, monkeypatch, cfg )
behaviour · function · L151-L152 — def behaviour(op, stage)
test_an_explicit_provider_refusal_stays_a_definite_failure · function · L169-L191 — def test_an_explicit_provider_refusal_stays_a_definite_failure(byoc, monkeypatch, cfg)
behaviour · function · L177-L179 — def behaviour(op, stage)
test_a_sandbox_the_dying_helper_named_is_recorded · function · L194-L217 — def test_a_sandbox_the_dying_helper_named_is_recorded(byoc, monkeypatch, cfg)
behaviour · function · L203-L205 — def behaviour(op, stage)
test_reconcile_flags_an_indeterminate_submit_as_an_orphan_risk · function · L220-L243 — def test_reconcile_flags_an_indeterminate_submit_as_an_orphan_risk( byoc, monkeypatch, cfg )
behaviour · function · L226-L228 — def behaviour(op, stage)
ssh_job · function · L252-L260 — def ssh_job(cfg, monkeypatch)
test_close_signals_the_ssh_job_it_claims_to_have_cancelled · function · L263-L281 — def test_close_signals_the_ssh_job_it_claims_to_have_cancelled( ssh_job, monkeypatch, cfg )
fake_run · function · L271-L273 — def fake_run(argv, **kw)
test_close_does_not_claim_a_cancel_it_could_not_deliver · function · L284-L303 — def test_close_does_not_claim_a_cancel_it_could_not_deliver(ssh_job, monkeypatch, cfg)
test_close_is_honest_when_the_host_is_unreachable · function · L306-L317 — def test_close_is_honest_when_the_host_is_unreachable(ssh_job, monkeypatch, cfg)
boom · function · L311-L312 — def boom(a, *k)
test_close_terminates_a_sandbox_it_only_knows_from_the_job_row · function · L320-L360 — def test_close_terminates_a_sandbox_it_only_knows_from_the_job_row( byoc, monkeypatch, cfg )
submit_ok · function · L328-L333 — def submit_ok(op, stage)
terminate_ok · function · L346-L351 — def terminate_ok(op, stage)
test_a_restart_does_not_hand_one_sessions_jobs_to_another · function · L363-L399 — def test_a_restart_does_not_hand_one_sessions_jobs_to_another( cfg, tmp_path, monkeypatch )
test_close_transitions_every_live_job_on_the_sandbox_it_terminated · function · L402-L444 — def test_close_transitions_every_live_job_on_the_sandbox_it_terminated( byoc, monkeypatch, cfg )
submit_ok · function · L412-L417 — def submit_ok(op, stage)
terminate_ok · function · L428-L430 — def terminate_ok(op, stage)
test_cancel_refuses_a_byoc_job_with_no_sandbox_to_terminate · function · L447-L458 — def test_cancel_refuses_a_byoc_job_with_no_sandbox_to_terminate(byoc, cfg)
test_cancel_that_cannot_reach_the_host_is_remote_unreachable · function · L461-L478 — def test_cancel_that_cannot_reach_the_host_is_remote_unreachable( ssh_job, monkeypatch, cfg )
boom · function · L468-L469 — def boom(a, *k)
test_cancel_of_a_finished_job_does_not_signal_the_remote · function · L481-L495 — def test_cancel_of_a_finished_job_does_not_signal_the_remote(ssh_job, monkeypatch, cfg)
fake_run · function · L487-L489 — def fake_run(a, *k)
test_cancel_maps_unsupported_terminate_to_provider_cancel_unsupported · function · L498-L534 — def test_cancel_maps_unsupported_terminate_to_provider_cancel_unsupported( byoc, monkeypatch, cfg )
submit_ok · function · L501-L506 — def submit_ok(op, stage)
no_cancel · function · L513-L525 — def no_cancel(op, stage)
test_a_provider_not_found_on_terminate_is_an_unconfirmed_cancel · function · L537-L570 — def test_a_provider_not_found_on_terminate_is_an_unconfirmed_cancel( byoc, monkeypatch, cfg )
submit_ok · function · L544-L549 — def submit_ok(op, stage)
gone · function · L556-L561 — def gone(op, stage)
test_a_terminal_state_cannot_be_clobbered_by_a_racing_writer · function · L578-L615 — def test_a_terminal_state_cannot_be_clobbered_by_a_racing_writer(cfg, monkeypatch)
check_then_interleave · function · L597-L609 — def check_then_interleave(job_id, current, requested)
test_only_one_of_two_concurrent_terminal_writes_wins · function · L618-L652 — def test_only_one_of_two_concurrent_terminal_writes_wins(cfg)
write · function · L630-L639 — def write(status)
test_a_status_write_on_a_missing_job_is_a_no_op · function · L655-L657 — def test_a_status_write_on_a_missing_job_is_a_no_op(cfg)
test_the_harvest_root_is_the_session_workspace · function · L665-L670 — def test_the_harvest_root_is_the_session_workspace(byoc, tmp_path)
test_a_manager_without_a_workspace_still_harvests · function · L673-L675 — def test_a_manager_without_a_workspace_still_harvests(cfg)
test_a_harvested_file_that_cannot_be_read_is_not_a_delivered_output · function · L678-L739 — def test_a_harvested_file_that_cannot_be_read_is_not_a_delivered_output( byoc, monkeypatch, cfg )
behaviour · function · L688-L695 — def behaviour(op, stage)
fake_harvest · function · L703-L714 — def fake_harvest(job_id, _stage)
test_a_transient_helper_reply_is_indeterminate_not_terminal · function · L747-L768 — def test_a_transient_helper_reply_is_indeterminate_not_terminal(byoc, monkeypatch, cfg)
behaviour · function · L755-L757 — def behaviour(op, stage)
test_a_rejection_that_cannot_be_persisted_is_not_a_clean_rejection · function · L771-L804 — def test_a_rejection_that_cannot_be_persisted_is_not_a_clean_rejection( byoc, monkeypatch, cfg )
behaviour · function · L778-L780 — def behaviour(op, stage)
flaky_update · function · L788-L791 — def flaky_update(job_id, **fields)