tests/test_compute_durability.py

• cfg · function · L35-L45 — def cfg(tmp_path)
• _Proc · class · L48-L67 — class _Proc
• init · method · L57-L61 — def init(self, returncode=0, stdout=b"", stderr=b"")
• wait · method · L63-L64 — def wait(self, timeout=None)
• kill · method · L66-L67 — def kill(self)
• _ack · function · L70-L78 — def _ack(pid, pgid=None)
• submitted · function · L82-L91 — def submitted(cfg, monkeypatch)
• test_a_job_survives_a_restart · function · L99-L103 — def test_a_job_survives_a_restart(cfg, submitted)
• test_the_handles_needed_to_reach_the_job_survive · function · L106-L114 — def test_the_handles_needed_to_reach_the_job_survive(cfg, submitted)
• test_a_recovered_job_still_occupies_its_concurrency_slot · function · L117-L121 — def test_a_recovered_job_still_occupies_its_concurrency_slot(cfg, submitted)
• _ssh_poll · function · L124-L135 — def _ssh_poll(rc: bytes)
• fake_run · function · L128-L133 — def fake_run(argv, **kw)
• test_a_recovered_job_can_still_be_polled · function · L138-L143 — def test_a_recovered_job_can_still_be_polled(cfg, submitted, monkeypatch)
• test_a_recovered_job_can_still_be_cancelled · function · L146-L159 — def test_a_recovered_job_can_still_be_cancelled(cfg, submitted, monkeypatch)
• fake_run · function · L153-L155 — def fake_run(argv, **kw)
• test_terminal_jobs_are_not_rehydrated · function · L162-L174 — def test_terminal_jobs_are_not_rehydrated(cfg, submitted, monkeypatch)
• fake_run · function · L166-L167 — def fake_run(argv, **kw)
• test_reconcile_surfaces_recovered_jobs_with_their_receipt · function · L182-L187 — def test_reconcile_surfaces_recovered_jobs_with_their_receipt(cfg, submitted)
• test_reconcile_does_not_resubmit · function · L190-L200 — def test_reconcile_does_not_resubmit(cfg, submitted, monkeypatch)
• forbidden · function · L196-L197 — def forbidden(a, *k)
• test_reconcile_is_empty_with_nothing_in_flight · function · L203-L208 — def test_reconcile_is_empty_with_nothing_in_flight(cfg)
• test_a_duplicate_idempotency_key_is_refused · function · L216-L228 — def test_a_duplicate_idempotency_key_is_refused(cfg, submitted, monkeypatch)
• test_the_key_survives_a_restart · function · L231-L242 — def test_the_key_survives_a_restart(cfg, submitted, monkeypatch)
• test_jobs_without_a_key_are_not_deduplicated · function · L245-L253 — def test_jobs_without_a_key_are_not_deduplicated(cfg, monkeypatch)
• test_a_concurrent_same_key_submit_is_refused_not_duplicated · function · L256-L308 — def test_a_concurrent_same_key_submit_is_refused_not_duplicated(cfg, monkeypatch)
• fake_run · function · L265-L267 — def fake_run(a, *k)
• racing_lookup · function · L287-L294 — def racing_lookup(key, owner_key=None, *, scoped=True): # The lookup is owner-scoped now: the idempotency namespace was # installation-wide while every other view of compute_jobs is # per-owner, so one session's key blocked every other session's.
• test_an_indeterminate_submit_leaves_a_reconcilable_row · function · L316-L334 — def test_an_indeterminate_submit_leaves_a_reconcilable_row(cfg, monkeypatch)
• boom · function · L321-L322 — def boom(a, *k)
• test_a_dropped_submit_receipt_degrades_to_reconcilable_not_clean_running · function · L337-L391 — def test_a_dropped_submit_receipt_degrades_to_reconcilable_not_clean_running( cfg, monkeypatch )
• failing_receipt_write · function · L362-L365 — def failing_receipt_write(job_id, **fields)
• test_a_receipt_write_to_a_missing_row_degrades_not_clean_running · function · L394-L421 — def test_a_receipt_write_to_a_missing_row_degrades_not_clean_running(cfg, monkeypatch)
• transient_create · function · L409-L410 — def transient_create(**_kw)
• test_a_rejected_submit_is_recorded_as_failed · function · L424-L437 — def test_a_rejected_submit_is_recorded_as_failed(cfg, monkeypatch)
• test_events_are_sequenced · function · L445-L449 — def test_events_are_sequenced(cfg, submitted)
• test_the_stream_records_how_a_job_reached_its_terminal_state · function · L452-L467 — def test_the_stream_records_how_a_job_reached_its_terminal_state( cfg, submitted, monkeypatch )
• fake_run · function · L459-L460 — def fake_run(argv, **kw)
• test_the_submitted_event_carries_the_receipt · function · L470-L473 — def test_the_submitted_event_carries_the_receipt(cfg, submitted)
• byoc · function · L487-L495 — def byoc(cfg, tmp_path)
• _helper · function · L498-L501 — def _helper(manager, monkeypatch, behaviour)
• test_a_byoc_create_that_may_have_landed_is_reconcilable · function · L504-L518 — def test_a_byoc_create_that_may_have_landed_is_reconcilable(byoc, monkeypatch, cfg)
• behaviour · function · L509-L510 — def behaviour(op)
• test_a_byoc_sandbox_survives_a_submit_that_failed_after_it · function · L521-L538 — def test_a_byoc_sandbox_survives_a_submit_that_failed_after_it(byoc, monkeypatch, cfg)
• behaviour · function · L526-L529 — def behaviour(op)
• test_a_byoc_submit_the_provider_refused_is_failed · function · L541-L555 — def test_a_byoc_submit_the_provider_refused_is_failed(byoc, monkeypatch, cfg)
• behaviour · function · L545-L546 — def behaviour(op)
• test_a_closed_job_does_not_come_back_to_life · function · L558-L570 — def test_a_closed_job_does_not_come_back_to_life(cfg, submitted)
• test_close_keeps_the_sandbox_id_when_terminate_fails · function · L573-L591 — def test_close_keeps_the_sandbox_id_when_terminate_fails(byoc, monkeypatch)
• behaviour · function · L578-L583 — def behaviour(op)
• test_close_releases_the_sandbox_once_the_provider_confirms · function · L594-L603 — def test_close_releases_the_sandbox_once_the_provider_confirms(byoc, monkeypatch)
• behaviour · function · L595-L596 — def behaviour(op)
• test_a_staged_input_cannot_choose_where_it_lands · function · L620-L633 — def test_a_staged_input_cannot_choose_where_it_lands(byoc, monkeypatch, tmp_path, dst)
• test_a_missing_input_fails_the_job_instead_of_running_without_it · function · L636-L651 — def test_a_missing_input_fails_the_job_instead_of_running_without_it( byoc, monkeypatch, tmp_path )
• test_a_legitimate_input_still_stages · function · L654-L666 — def test_a_legitimate_input_still_stages(byoc, monkeypatch, tmp_path)
• test_a_manager_without_a_store_still_runs_jobs · function · L669-L679 — def test_a_manager_without_a_store_still_runs_jobs(cfg, monkeypatch)
• test_a_job_that_never_produced_its_declared_outputs_is_not_a_success · function · L687-L712 — def test_a_job_that_never_produced_its_declared_outputs_is_not_a_success( byoc, monkeypatch, cfg )
• behaviour · function · L694-L699 — def behaviour(op)
• test_a_harvest_is_recorded_with_hashes · function · L715-L752 — def test_a_harvest_is_recorded_with_hashes(byoc, monkeypatch, cfg)
• behaviour · function · L719-L724 — def behaviour(op)
• fake_harvest · function · L729-L734 — def fake_harvest(job_id, _stage)
• test_featured_files_is_the_declared_subset · function · L755-L782 — def test_featured_files_is_the_declared_subset(byoc, monkeypatch)
• behaviour · function · L759-L764 — def behaviour(op)
• fake_harvest · function · L768-L774 — def fake_harvest(job_id, _stage)
• _capture_submits · function · L790-L799 — def _capture_submits(manager, monkeypatch, behaviour)
• run_helper · function · L794-L796 — def run_helper(self, prov, op, req, a, *k)
• _sandbox_behaviour · function · L802-L807 — def _sandbox_behaviour(op)
• test_a_declared_container_lifetime_arms_the_wrapper_watchdog · function · L810-L829 — def test_a_declared_container_lifetime_arms_the_wrapper_watchdog(byoc, monkeypatch)
• test_a_reused_sandbox_inherits_the_time_it_has_already_spent · function · L832-L850 — def test_a_reused_sandbox_inherits_the_time_it_has_already_spent(byoc, monkeypatch)
• test_no_declared_lifetime_leaves_the_watchdog_unarmed · function · L853-L864 — def test_no_declared_lifetime_leaves_the_watchdog_unarmed(byoc, monkeypatch)
• test_closing_a_sandbox_forgets_its_deadline · function · L867-L881 — def test_closing_a_sandbox_forgets_its_deadline(byoc, monkeypatch)