tests/test_cluster_session_e2e.py

• launching_cluster · function · L53-L169 — def launching_cluster(tmp_path, monkeypatch)
• _Cluster · class · L152-L167 — class _Cluster
• read · method · L155-L164 — def read(self, name)
• write · method · L166-L167 — def write(self, name, value)
• _Harness · class · L172-L189 — class _Harness
• init · method · L175-L181 — def init(self, tmp_path, gateway, store, manager, reconciler)
• close · method · L183-L189 — def close(self)
• harness · function · L193-L224 — def harness(tmp_path, launching_cluster)
• _bring_up · function · L227-L258 — def _bring_up(harness, session_id="s1", *, timeout_s=30.0)
• test_a_submitted_session_brings_up_a_real_worker_that_dials_back · function · L264-L269 — def test_a_submitted_session_brings_up_a_real_worker_that_dials_back(harness)
• test_variables_survive_across_turns · function · L272-L278 — def test_variables_survive_across_turns(harness)
• test_the_credential_is_single_use_even_on_the_real_path · function · L281-L295 — def test_the_credential_is_single_use_even_on_the_real_path(harness)
• test_nothing_secret_reached_the_job_script_or_its_environment · function · L298-L311 — def test_nothing_secret_reached_the_job_script_or_its_environment( harness, launching_cluster )
• test_an_interrupt_reaches_a_worker_the_daemon_has_no_pid_for · function · L314-L319 — def test_an_interrupt_reaches_a_worker_the_daemon_has_no_pid_for(harness)
• test_cancelling_a_session_releases_the_resource · function · L322-L336 — def test_cancelling_a_session_releases_the_resource(harness, launching_cluster)
• test_a_lapsed_lease_takes_the_resource_back · function · L339-L372 — def test_a_lapsed_lease_takes_the_resource_back(harness, launching_cluster)
• test_an_expired_credential_cannot_bring_a_worker_up · function · L375-L385 — def test_an_expired_credential_cannot_bring_a_worker_up(harness, tmp_path)
• test_a_worker_from_a_stale_epoch_is_refused_by_the_live_gateway · function · L388-L405 — def test_a_worker_from_a_stale_epoch_is_refused_by_the_live_gateway(harness)
• test_two_sessions_get_two_workers_and_do_not_share_state · function · L408-L418 — def test_two_sessions_get_two_workers_and_do_not_share_state(harness)