tests/test_gateway_kernel_lifecycle.py

• _Hub · class · L19-L35 — class _Hub
• init · method · L20-L21 — def init(self) -> None
• emitter · method · L23-L28 — def emitter(self, root_frame_id: str)
• emit · function · L24-L26 — def emit(event: dict) -> None
• broadcast · method · L30-L32 — def broadcast(self, root_frame_id: str, event: dict) -> None
• has_subscriber · method · L34-L35 — def has_subscriber(self, root_frame_id: str) -> bool
• _runner · function · L38-L45 — def _runner(tmp_path, *, team_mode: bool = False)
• _RecordingKernel · class · L48-L90 — class _RecordingKernel
• init · method · L49-L60 — def init(self, name: str, events: list[str] | None = None) -> None
• is_alive · method · L62-L63 — def is_alive(self) -> bool
• execute · method · L65-L70 — def execute(self, code, origin="agent", on_chunk=None, *, cell_id=None)
• interrupt · method · L72-L76 — def interrupt(self) -> None
• shutdown · method · L78-L81 — def shutdown(self) -> None
• restart · method · L83-L85 — def restart(self) -> None
• kill_worker · method · L87-L90 — def kill_worker(self) -> None
• test_stop_interrupts_both_slots_then_waits_for_execution_barrier · function · L93-L121 — def test_stop_interrupts_both_slots_then_waits_for_execution_barrier(tmp_path)
• execute_turn · function · L103-L105 — def execute_turn() -> None
• test_stop_intent_cannot_be_overtaken_by_a_new_start · function · L124-L180 — def test_stop_intent_cannot_be_overtaken_by_a_new_start(monkeypatch, tmp_path)
• paused_cancel · function · L133-L136 — def paused_cancel(root_frame_id: str, *, reason: str) -> None
• ensure · function · L142-L144 — def ensure(state) -> None
• start · function · L156-L158 — def start() -> None
• test_ensure_replaces_a_dead_supervised_python_worker · function · L183-L201 — def test_ensure_replaces_a_dead_supervised_python_worker(monkeypatch, tmp_path)
• spawn · function · L192-L194 — def spawn(state)
• test_python_bootstrap_runs_outside_supervisor_lock · function · L204-L301 — def test_python_bootstrap_runs_outside_supervisor_lock(monkeypatch, tmp_path)
• BlockingBootstrapKernel · class · L228-L268 — class BlockingBootstrapKernel
• init · method · L232-L238 — def init(self, dispatcher, **kwargs) -> None
• is_alive · method · L240-L241 — def is_alive(self) -> bool
• execute · method · L243-L262 — def execute(self, code, origin="agent", on_chunk=None)
• interrupt · method · L264-L265 — def interrupt(self) -> None
• shutdown · method · L267-L268 — def shutdown(self) -> None
• spawn · function · L273-L276 — def spawn() -> None
• interrupt · function · L287-L289 — def interrupt() -> None
• test_environment_replacement_keeps_session_dispatcher_and_commits_active_env · function · L304-L415 — def test_environment_replacement_keeps_session_dispatcher_and_commits_active_env( monkeypatch, tmp_path )
• Dispatcher · class · L338-L344 — class Dispatcher
• init · method · L339-L341 — def init(self) -> None
• call · method · L343-L344 — def call(self, method, args)
• make_dispatcher · function · L346-L349 — def make_dispatcher(args, *kwargs)
• FakeKernel · class · L354-L370 — class FakeKernel
• init · method · L355-L363 — def init(self, dispatcher, python, **kwargs) -> None
• is_alive · method · L365-L366 — def is_alive(self) -> bool
• shutdown · method · L368-L370 — def shutdown(self) -> None
• test_team_mode_composes_read_isolation_into_every_local_kernel · function · L418-L487 — def test_team_mode_composes_read_isolation_into_every_local_kernel( monkeypatch, tmp_path )
• FakeKernel · class · L442-L453 — class FakeKernel
• init · method · L443-L447 — def init(self, dispatcher, **options) -> None
• is_alive · method · L449-L450 — def is_alive(self) -> bool
• shutdown · method · L452-L453 — def shutdown(self) -> None
• spawn_r_kernel · function · L470-L472 — def spawn_r_kernel(**options)
• test_team_first_action_background_cell_gets_read_isolation · function · L490-L541 — def test_team_first_action_background_cell_gets_read_isolation(monkeypatch, tmp_path)
• FakeKernel · class · L503-L515 — class FakeKernel
• init · method · L504-L507 — def init(self, dispatcher, **options) -> None
• execute · method · L509-L512 — def execute(self, code, origin="agent", on_chunk=None)
• shutdown · method · L514-L515 — def shutdown(self) -> None
• test_team_read_policy_covers_data_personal_and_only_current_project_sidecars · function · L544-L587 — def test_team_read_policy_covers_data_personal_and_only_current_project_sidecars( monkeypatch, tmp_path, )
• test_team_read_policy_rejects_symlinked_personal_namespace_and_root_overlap · function · L590-L618 — def test_team_read_policy_rejects_symlinked_personal_namespace_and_root_overlap( monkeypatch, tmp_path, )
• test_team_read_policy_rejects_symlinked_artifact_input_scope · function · L621-L631 — def test_team_read_policy_rejects_symlinked_artifact_input_scope(tmp_path)
• test_r_slot_is_lazy_reused_and_soft_fails_without_touching_python · function · L634-L683 — def test_r_slot_is_lazy_reused_and_soft_fails_without_touching_python( monkeypatch, tmp_path )
• get_environment · function · L647-L648 — def get_environment(name)
• spawn_r_kernel · function · L650-L657 — def spawn_r_kernel(*, cwd, env, read_isolation=None)
• test_r_execution_exception_shuts_down_the_exact_desynchronized_lease · function · L686-L710 — def test_r_execution_exception_shuts_down_the_exact_desynchronized_lease(tmp_path)
• BrokenR · class · L691-L693 — class BrokenR(_RecordingKernel)
• execute · method · L692-L693 — def execute(self, code, origin="agent", on_chunk=None, *, cell_id=None)
• test_watchdog_passes_canonical_cell_id_to_kernel · function · L713-L743 — def test_watchdog_passes_canonical_cell_id_to_kernel(tmp_path)
• ImmediateKernel · class · L718-L730 — class ImmediateKernel
• is_alive · method · L719-L720 — def is_alive(self)
• execute · method · L722-L724 — def execute(self, code, origin="agent", on_chunk=None, *, cell_id=None)
• interrupt · method · L726-L727 — def interrupt(self)
• shutdown · method · L729-L730 — def shutdown(self)
• test_watchdog_hard_kill_restarts_exact_python_lease · function · L746-L776 — def test_watchdog_hard_kill_restarts_exact_python_lease(monkeypatch, tmp_path)
• HungKernel · class · L750-L757 — class HungKernel(_RecordingKernel)
• execute · method · L751-L754 — def execute(self, code, origin="agent", on_chunk=None, *, cell_id=None)
• interrupt · method · L756-L757 — def interrupt(self) -> None