tests/test_orchestration_distributed.py

_allocation · function · L48-L57 — def _allocation(job_id: str | None = "4242") -> Allocation
test_the_step_names_the_job_it_runs_inside · function · L63-L75 — def test_the_step_names_the_job_it_runs_inside()
test_a_workload_holding_nothing_is_refused_rather_than_given_a_new_job · function · L78-L82 — def test_a_workload_holding_nothing_is_refused_rather_than_given_a_new_job()
test_the_step_is_run_through_the_real_argv · function · L85-L108 — def test_the_step_is_run_through_the_real_argv(monkeypatch)
fake_runner · function · L88-L97 — def fake_runner(command, **kwargs)
_Done · class · L92-L95 — class _Done
test_a_slurm_backend_is_a_task_runner · function · L111-L114 — def test_a_slurm_backend_is_a_task_runner()
test_a_step_refuses_a_credential_shaped_environment_name · function · L117-L121 — def test_a_step_refuses_a_credential_shaped_environment_name()
test_a_step_refuses_an_unsafe_job_id · function · L124-L127 — def test_a_step_refuses_an_unsafe_job_id()
test_a_slurm_worker_selects_the_credential_for_its_rank · function · L130-L139 — def test_a_slurm_worker_selects_the_credential_for_its_rank(monkeypatch)
gateway · function · L146-L153 — def gateway(tmp_path)
_dial · function · L156-L163 — def _dial(gateway, credential)
test_every_rank_is_kept_not_just_the_last_one · function · L166-L179 — def test_every_rank_is_kept_not_just_the_last_one(gateway)
test_waiting_for_a_gang_returns_the_partial_set_on_timeout · function · L182-L190 — def test_waiting_for_a_gang_returns_the_partial_set_on_timeout(gateway)
test_a_timed_out_wait_keeps_the_partial_set_for_the_next_one · function · L193-L219 — def test_a_timed_out_wait_keeps_the_partial_set_for_the_next_one(gateway)
test_an_unawaited_registration_is_reaped · function · L222-L247 — def test_an_unawaited_registration_is_reaped(gateway, monkeypatch)
test_a_live_bound_session_registration_survives_orphan_housekeeping · function · L250-L309 — def test_a_live_bound_session_registration_survives_orphan_housekeeping( tmp_path, monkeypatch )
test_a_wait_timeout_sweeps_an_orphan_that_arrived_after_the_first_check · function · L312-L357 — def test_a_wait_timeout_sweeps_an_orphan_that_arrived_after_the_first_check( gateway, monkeypatch )
_Transport · class · L326-L330 — class _Transport
close · method · L329-L330 — def close(self, *, graceful=True)
reap_then_plant_once · function · L343-L351 — def reap_then_plant_once()
test_a_late_rank_completes_the_gang · function · L360-L383 — def test_a_late_rank_completes_the_gang(gateway)
arrive_later · function · L366-L372 — def arrive_later()
test_a_multi_node_session_is_not_ready_on_one_rank · function · L386-L428 — def test_a_multi_node_session_is_not_ready_on_one_rank(tmp_path)
_PartialGateway · class · L392-L397 — class _PartialGateway
await_workers · method · L393-L394 — def await_workers(self, allocation_id, epoch, *, expected, timeout_s)
await_worker · method · L396-L397 — def await_worker(self, allocation_id, epoch, *, timeout_s)
test_a_reaped_partial_rank_cannot_satisfy_later_gang_readiness · function · L431-L491 — def test_a_reaped_partial_rank_cannot_satisfy_later_gang_readiness(tmp_path)
_Transport · class · L442-L447 — class _Transport
init · method · L443-L444 — def init(self)
alive · method · L446-L447 — def alive(self)
_Rank · class · L449-L452 — class _Rank
init · method · L450-L452 — def init(self, rank)
_Gateway · class · L458-L460 — class _Gateway
await_workers · method · L459-L460 — def await_workers(self, allocation_id, epoch, *, expected, timeout_s)
test_a_single_node_session_does_not_have_to_count · function · L494-L502 — def test_a_single_node_session_does_not_have_to_count(tmp_path)