tests/test_gateway.py

• _Hub · class · L23-L36 — class _Hub
• init · method · L24-L25 — def init(self)
• emitter · method · L27-L32 — def emitter(self, root_frame_id)
• emit · function · L28-L30 — def emit(event)
• broadcast · method · L34-L36 — def broadcast(self, root_frame_id, event)
• test_a_fresh_daemon_seeds_no_demo_and_the_variable_now_opts_in · function · L39-L56 — def test_a_fresh_daemon_seeds_no_demo_and_the_variable_now_opts_in(monkeypatch)
• test_a_fresh_boot_starts_no_kernel_and_executes_no_cell · function · L59-L96 — def test_a_fresh_boot_starts_no_kernel_and_executes_no_cell(tmp_path, monkeypatch)
• test_the_example_seed_is_on_demand_idempotent_and_single_flight · function · L99-L134 — def test_the_example_seed_is_on_demand_idempotent_and_single_flight( tmp_path, monkeypatch )
• _slow_seed · function · L115-L117 — def _slow_seed(_cfg, _runner)
• test_the_example_seed_route_reports_state_and_surfaces_its_error · function · L137-L189 — def test_the_example_seed_route_reports_state_and_surfaces_its_error( tmp_path, monkeypatch )
• _boom · function · L175-L176 — def _boom(_cfg, _runner)
• test_the_example_seed_route_reports_the_already_seeded_state · function · L192-L271 — def test_the_example_seed_route_reports_the_already_seeded_state(tmp_path, monkeypatch)
• _handler_for · function · L218-L223 — def _handler_for(active_runner)
• _boom · function · L227-L228 — def _boom(_cfg, _runner)
• test_a_confirmed_seed_completes_without_an_attached_approver · function · L274-L345 — def test_a_confirmed_seed_completes_without_an_attached_approver(tmp_path, monkeypatch)
• _seed_with_fake_cells · function · L348-L396 — def _seed_with_fake_cells(tmp_path, monkeypatch, cell_behaviour)
• _fake_run_repl · function · L361-L379 — def _fake_run_repl(self, root_frame_id, project_id, code, args, *kwargs)
• register · function · L364-L374 — def register(name)
• test_the_example_seed_message_lists_only_materials_that_really_exist · function · L399-L452 — def test_the_example_seed_message_lists_only_materials_that_really_exist( tmp_path, monkeypatch )
• behaviour · function · L413-L431 — def behaviour(index, register)
• test_the_example_seed_message_keeps_the_full_claim_when_everything_ran · function · L455-L482 — def test_the_example_seed_message_keeps_the_full_claim_when_everything_ran( tmp_path, monkeypatch )
• behaviour · function · L461-L470 — def behaviour(index, register)
• test_the_example_seed_counts_interrupted_cells_as_failures · function · L485-L511 — def test_the_example_seed_counts_interrupted_cells_as_failures(tmp_path, monkeypatch)
• behaviour · function · L492-L504 — def behaviour(index, register)
• test_build_app_server_closes_runner_when_startup_raises_before_bind · function · L514-L539 — def test_build_app_server_closes_runner_when_startup_raises_before_bind( tmp_path, monkeypatch )
• spying_close · function · L525-L527 — def spying_close(self)
• test_server_close_drops_datapro_connection_bound_to_old_secret_store · function · L543-L598 — def test_server_close_drops_datapro_connection_bound_to_old_secret_store( tmp_path, monkeypatch )
• _Connection · class · L552-L568 — class _Connection
• init · method · L555-L557 — def init(self, config)
• faulted · method · L559-L560 — def faulted(self)
• list_tools · method · L562-L564 — def list_tools(self)
• close · method · L566-L568 — def close(self)
• generation · function · L582-L594 — def generation(path, key)
• test_ws_resume_buffer_replaces_notebook_drafts_and_keeps_live_cell_events · function · L601-L647 — def test_ws_resume_buffer_replaces_notebook_drafts_and_keeps_live_cell_events()
• test_ws_resume_coalesces_notebook_and_activity_stdout_independently · function · L650-L724 — def test_ws_resume_coalesces_notebook_and_activity_stdout_independently()
• test_ws_stray_state_does_not_create_phantom_live_buffer_and_repl_is_bounded · function · L727-L783 — def test_ws_stray_state_does_not_create_phantom_live_buffer_and_repl_is_bounded()
• test_ws_resume_trim_preserves_active_cell_start_before_tail_chunks · function · L786-L820 — def test_ws_resume_trim_preserves_active_cell_start_before_tail_chunks()
• test_ws_subscribe_replay_enqueue_is_atomic_with_live_broadcast · function · L823-L883 — def test_ws_subscribe_replay_enqueue_is_atomic_with_live_broadcast()
• BlockingConnection · class · L829-L852 — class BlockingConnection
• init · method · L830-L835 — def init(self)
• refresh_visibility · method · L837-L839 — def refresh_visibility(self, root_frame_id)
• may_receive · method · L841-L846 — def may_receive(self, root_frame_id)
• send_json · method · L848-L852 — def send_json(self, event)
• test_ws_broadcast_refreshes_a_subscription_added_during_authorization · function · L886-L940 — def test_ws_broadcast_refreshes_a_subscription_added_during_authorization()
• CheckedConnection · class · L897-L918 — class CheckedConnection
• init · method · L898-L905 — def init(self, *, block_first=False)
• refresh_visibility · method · L907-L912 — def refresh_visibility(self, root_frame_id)
• may_receive · method · L914-L915 — def may_receive(self, root_frame_id)
• send_json · method · L917-L918 — def send_json(self, event)
• test_ws_restored_visibility_replays_the_denied_sequence_gap · function · L943-L981 — def test_ws_restored_visibility_replays_the_denied_sequence_gap()
• VisibilityConnection · class · L947-L962 — class VisibilityConnection
• init · method · L952-L959 — def init(self)
• send_json · method · L961-L962 — def send_json(self, event)
• test_ws_idle_delta_gap_is_declared_when_visibility_returns · function · L984-L1019 — def test_ws_idle_delta_gap_is_declared_when_visibility_returns()
• VisibilityConnection · class · L988-L1003 — class VisibilityConnection
• init · method · L993-L1000 — def init(self)
• send_json · method · L1002-L1003 — def send_json(self, event)
• test_ws_replay_declares_an_unbuffered_idle_delta_at_the_tail · function · L1022-L1038 — def test_ws_replay_declares_an_unbuffered_idle_delta_at_the_tail()
• test_ws_outbound_queue_covers_a_complete_resume_envelope · function · L1041-L1047 — def test_ws_outbound_queue_covers_a_complete_resume_envelope()
• test_ws_connection_byte_budget_drops_and_clears_queued_accounting · function · L1050-L1072 — def test_ws_connection_byte_budget_drops_and_clears_queued_accounting()
• PausedConnection · class · L1051-L1058 — class PausedConnection(gateway_mod.WSConnection)
• init · method · L1052-L1054 — def init(self)
• _drain · method · L1056-L1058 — def _drain(self)
• test_ws_connection_counts_a_socket_blocked_frame_against_byte_budget · function · L1075-L1102 — def test_ws_connection_counts_a_socket_blocked_frame_against_byte_budget()
• BlockingWriter · class · L1076-L1087 — class BlockingWriter
• init · method · L1077-L1079 — def init(self)
• write · method · L1081-L1084 — def write(self, frame)
• flush · method · L1086-L1087 — def flush(self)
• test_ws_resume_byte_budget_keeps_reset_active_start_and_latest_tail · function · L1105-L1142 — def test_ws_resume_byte_budget_keeps_reset_active_start_and_latest_tail()
• test_ws_live_frame_limit_is_hard_even_when_every_buffer_is_running · function · L1145-L1153 — def test_ws_live_frame_limit_is_hard_even_when_every_buffer_is_running()
• _auth_headers · function · L1156-L1168 — def _auth_headers(cfg, extra: dict | None = None) -> dict
• _cfg · function · L1171-L1176 — def _cfg(tmp_path)
• test_example_connector_seed_removes_only_the_old_default_qualifier · function · L1179-L1193 — def test_example_connector_seed_removes_only_the_old_default_qualifier(tmp_path)
• test_builtin_connector_commands_migrate_across_servers · function · L1196-L1249 — def test_builtin_connector_commands_migrate_across_servers(tmp_path)
• test_protein_connector_migration_preserves_operator_metadata · function · L1252-L1268 — def test_protein_connector_migration_preserves_operator_metadata(tmp_path)
• _stage1_cfg · function · L1271-L1277 — def _stage1_cfg(tmp_path)
• _stage1_stage4_cfg · function · L1280-L1289 — def _stage1_stage4_cfg(tmp_path)
• test_guardian_circuit_terminalizes_the_gateway_auto_run · function · L1292-L1376 — def test_guardian_circuit_terminalizes_the_gateway_auto_run(tmp_path)
• hit_open_circuit · function · L1337-L1351 — def hit_open_circuit(state, _emit, _visible)
• _readiness · function · L1379-L1457 — def _readiness(*, state="ready")
• _write_standard_generation_fixture · function · L1460-L1508 — def _write_standard_generation_fixture( root: Path, *, missing: set[tuple[str, str]] | None = None, ) -> None
• _production_environment_status_route · function · L1511-L1525 — def _production_environment_status_route(cfg: Config) -> dict
• test_environment_status_route_captures_flag_off_production_projection · function · L1528-L1540 — def test_environment_status_route_captures_flag_off_production_projection(tmp_path)
• test_environment_status_route_captures_ready_production_metadata · function · L1543-L1566 — def test_environment_status_route_captures_ready_production_metadata( tmp_path, monkeypatch )
• test_environment_status_route_captures_both_missing_package_lists · function · L1569-L1597 — def test_environment_status_route_captures_both_missing_package_lists( tmp_path, monkeypatch )
• test_environment_status_route_captures_package_inventory_failure · function · L1600-L1635 — def test_environment_status_route_captures_package_inventory_failure( tmp_path, monkeypatch )
• unavailable_inventory · function · L1613-L1615 — def unavailable_inventory(args, *kwargs)
• test_stage1_readiness_does_not_block_an_ordinary_control_only_turn · function · L1638-L1664 — def test_stage1_readiness_does_not_block_an_ordinary_control_only_turn( tmp_path, monkeypatch )
• forbidden_readiness · function · L1646-L1647 — def forbidden_readiness()
• test_stage1_readiness_allows_plan_draft_but_refuses_approve_and_resume_pre_cas · function · L1667-L1745 — def test_stage1_readiness_allows_plan_draft_but_refuses_approve_and_resume_pre_cas( tmp_path, monkeypatch )
• plan_turn · function · L1682-L1695 — def plan_turn( root_frame_id, project_id, user_text, model=None, plan=False, annos=None, explore=False, frozen_binding=None, task_mode=None, )
• must_not_claim · function · L1732-L1734 — def must_not_claim(*_args)
• test_stage1_direct_notebook_cell_hits_readiness_before_any_cell_fact · function · L1748-L1780 — def test_stage1_direct_notebook_cell_hits_readiness_before_any_cell_fact( tmp_path, monkeypatch )
• test_environment_status_exposes_stage1_readiness_as_a_top_level_projection · function · L1783-L1799 — def test_environment_status_exposes_stage1_readiness_as_a_top_level_projection( tmp_path, monkeypatch )
• test_permission_resolution_does_not_create_live_turn_buffer · function · L1802-L1814 — def test_permission_resolution_does_not_create_live_turn_buffer()
• test_completion_nudge_falls_back_to_code_for_no_tool_endpoint · function · L1817-L1834 — def test_completion_nudge_falls_back_to_code_for_no_tool_endpoint(monkeypatch)
• test_gateway_plain_answer_is_nudged_to_structured_finalize_without_kernel · function · L1837-L1921 — def test_gateway_plain_answer_is_nudged_to_structured_finalize_without_kernel( monkeypatch, tmp_path )
• fake_chat · function · L1877-L1882 — def fake_chat(messages, cfg, on_delta=None, **kwargs)
• fake_ensure · function · L1884-L1887 — def fake_ensure(st)
• fake_exec · function · L1889-L1890 — def fake_exec(args, *kwargs)
• test_gateway_projects_submit_only_result_as_live_and_persisted_final_message · function · L1924-L1970 — def test_gateway_projects_submit_only_result_as_live_and_persisted_final_message( monkeypatch, tmp_path )
• fake_ensure · function · L1933-L1936 — def fake_ensure(st)
• finish_without_model_prose · function · L1938-L1945 — def finish_without_model_prose(st, emit, visible)
• test_stage4_persists_one_canonical_candidate_before_one_review · function · L1973-L2086 — def test_stage4_persists_one_canonical_candidate_before_one_review( monkeypatch, tmp_path )
• fake_ensure · function · L1986-L1989 — def fake_ensure(state)
• finish_with_two_prose_blocks · function · L1991-L2004 — def finish_with_two_prose_blocks(state, emit, visible)
• _Gate · class · L2006-L2042 — class _Gate
• active_mode · method · L2008-L2009 — def active_mode(_root_frame_id)
• gate_after_turn · method · L2011-L2025 — def gate_after_turn(self, **fields)
• finalize_after_delivery · method · L2027-L2042 — def finalize_after_delivery(self, **fields)
• test_stage3_prestart_freezes_real_selection_when_stage4_is_off · function · L2089-L2174 — def test_stage3_prestart_freezes_real_selection_when_stage4_is_off( monkeypatch, tmp_path )
• fake_ensure · function · L2116-L2119 — def fake_ensure(state)
• finish · function · L2121-L2133 — def finish(state, emit, visible)
• pass_review · function · L2135-L2139 — def pass_review(_messages, _config, **_kwargs)
• test_stop_after_review_wins_the_gateway_terminal_proposal · function · L2177-L2247 — def test_stop_after_review_wins_the_gateway_terminal_proposal(monkeypatch, tmp_path)
• fake_ensure · function · L2185-L2188 — def fake_ensure(state)
• finish · function · L2190-L2202 — def finish(state, emit, visible)
• _Gate · class · L2204-L2229 — class _Gate
• active_mode · method · L2206-L2207 — def active_mode(_root_frame_id)
• gate_after_turn · method · L2209-L2221 — def gate_after_turn(self, **fields): # This is the narrow window after review returns but before the # gateway crosses the atomic finalizing boundary.
• finalize_after_delivery · method · L2223-L2229 — def finalize_after_delivery(self, **fields)
• _content_disposition_names · function · L2250-L2261 — def _content_disposition_names(value: str) -> tuple[str, str, str]
• test_artifact_bytes_carry_an_inline_disposition_with_the_artifact_filename · function · L2264-L2378 — def test_artifact_bytes_carry_an_inline_disposition_with_the_artifact_filename( tmp_path, )
• fetch · function · L2299-L2306 — def fetch(path)
• _install_artifact_submission · function · L2381-L2417 — def _install_artifact_submission( monkeypatch, runner, *, filename="result.csv", content=b"sample,score\nA,1\n", cell_id="cell-stage1", after_capture=None, )
• fake_ensure · function · L2393-L2396 — def fake_ensure(state)
• finish_with_artifact · function · L2398-L2412 — def finish_with_artifact(state, emit, visible)
• test_stage1_flag_off_keeps_legacy_completion_and_skips_delivery_ledger · function · L2420-L2456 — def test_stage1_flag_off_keeps_legacy_completion_and_skips_delivery_ledger( tmp_path, monkeypatch )
• test_default_completion_artifact_links_are_served_over_the_real_socket · function · L2459-L2551 — def test_default_completion_artifact_links_are_served_over_the_real_socket( tmp_path, monkeypatch )
• fetch · function · L2496-L2503 — def fetch(path)
• test_stage1_same_head_capture_is_verified_committed_then_emitted_and_reopens_once · function · L2554-L2669 — def test_stage1_same_head_capture_is_verified_committed_then_emitted_and_reopens_once( tmp_path, monkeypatch )
• assert_no_link_was_emitted · function · L2584-L2590 — def assert_no_link_was_emitted()
• observed_build · function · L2592-L2596 — def observed_build(**kwargs)
• observed_commit · function · L2598-L2612 — def observed_commit(**kwargs)
• test_stage4_reviews_the_exact_same_head_version_in_the_stage1_manifest · function · L2672-L2743 — def test_stage4_reviews_the_exact_same_head_version_in_the_stage1_manifest( tmp_path, monkeypatch )
• _Gate · class · L2694-L2726 — class _Gate
• active_mode · method · L2696-L2697 — def active_mode(_root_frame_id)
• gate_after_turn · method · L2699-L2722 — def gate_after_turn(self, **fields)
• finalize_after_delivery · method · L2724-L2726 — def finalize_after_delivery(self, **fields)
• test_stage4_never_publishes_a_stage1_manifest_the_repair_did_not_review · function · L2746-L2812 — def test_stage4_never_publishes_a_stage1_manifest_the_repair_did_not_review( tmp_path, monkeypatch )
• _Gate · class · L2759-L2789 — class _Gate
• active_mode · method · L2761-L2762 — def active_mode(_root_frame_id)
• gate_after_turn · method · L2764-L2784 — def gate_after_turn(self, **fields)
• finalize_after_delivery · method · L2786-L2789 — def finalize_after_delivery(self, **fields)
• test_stage1_candidate_commit_lost_response_replays_exactly_once · function · L2815-L2856 — def test_stage1_candidate_commit_lost_response_replays_exactly_once( tmp_path, monkeypatch )
• commit_then_lose_response · function · L2829-L2834 — def commit_then_lose_response(**fields)
• test_stage1_publish_marker_fault_leaves_one_committed_message_for_recovery · function · L2859-L2924 — def test_stage1_publish_marker_fault_leaves_one_committed_message_for_recovery( tmp_path, monkeypatch )
• lose_publication_marker · function · L2873-L2875 — def lose_publication_marker(delivery_id)
• test_stage1_delivery_pin_rejects_delete_between_commit_and_link_emit · function · L2927-L2996 — def test_stage1_delivery_pin_rejects_delete_between_commit_and_link_emit( tmp_path, monkeypatch )
• commit_then_pause · function · L2944-L2948 — def commit_then_pause(**kwargs)
• run_turn · function · L2953-L2959 — def run_turn()
• test_stage1_artifact_delivery_faults_fail_closed_without_a_success_link · function · L3000-L3064 — def test_stage1_artifact_delivery_faults_fail_closed_without_a_success_link( tmp_path, monkeypatch, fault )
• damage_snapshot · function · L3011-L3020 — def damage_snapshot(record)
• test_stage1_commit_rechecks_snapshot_bytes_after_manifest_build · function · L3067-L3109 — def test_stage1_commit_rechecks_snapshot_bytes_after_manifest_build( tmp_path, monkeypatch )
• build_then_mutate · function · L3083-L3092 — def build_then_mutate(**kwargs)
• test_stage1_messages_route_refuses_a_corrupt_delivery_ledger · function · L3112-L3162 — def test_stage1_messages_route_refuses_a_corrupt_delivery_ledger(tmp_path)
• test_submit_message_runs_turn_in_background · function · L3165-L3201 — def test_submit_message_runs_turn_in_background(tmp_path)
• fake_run · function · L3171-L3191 — def fake_run( root_frame_id, project_id, user_text, model=None, plan=False, annos=None, explore=False, # What the item was ACCEPTED under, carried from the request thread. The # freeze used to be written only to the frame, whose pin the rebind route # rewrites by design -- so a queued follow-up could adopt it after 202. frozen_binding=None, task_mode=None, )
• test_annotation_store_crud_and_send_folding · function · L3204-L3253 — def test_annotation_store_crud_and_send_folding(tmp_path)
• _runner_frame · function · L3257-L3263 — def _runner_frame(tmp_path)
• test_auto_capture_preserves_version_bytes · function · L3266-L3308 — def test_auto_capture_preserves_version_bytes(tmp_path)
• test_restore_version_appends_fresh_current_version · function · L3311-L3344 — def test_restore_version_appends_fresh_current_version(tmp_path)
• test_restore_route_returns_fresh_identity_and_surfaces_verification_error · function · L3347-L3384 — def test_restore_route_returns_fresh_identity_and_surfaces_verification_error( tmp_path, )
• test_save_artifact_atomic_and_delete_cleans_snapshots · function · L3387-L3407 — def test_save_artifact_atomic_and_delete_cleans_snapshots(tmp_path)
• test_explore_mode_injects_protocol_and_nudges_prose_stalls · function · L3410-L3447 — def test_explore_mode_injects_protocol_and_nudges_prose_stalls(monkeypatch, tmp_path)
• fake_chat · function · L3421-L3423 — def fake_chat(messages, cfg, on_delta=None, **kwargs)
• fake_ensure · function · L3425-L3428 — def fake_ensure(st)
• test_explore_flag_passes_through_submit_message · function · L3450-L3480 — def test_explore_flag_passes_through_submit_message(tmp_path)
• fake_run · function · L3455-L3471 — def fake_run( root_frame_id, project_id, user_text, model=None, plan=False, annos=None, explore=False, # What the item was ACCEPTED under, carried from the request thread. The # freeze used to be written only to the frame, whose pin the rebind route # rewrites by design -- so a queued follow-up could adopt it after 202. frozen_binding=None, task_mode=None, )
• test_midtask_prose_conclusion_still_requires_structured_submit · function · L3483-L3534 — def test_midtask_prose_conclusion_still_requires_structured_submit( monkeypatch, tmp_path )
• fake_chat · function · L3502-L3504 — def fake_chat(messages, cfg, on_delta=None, **kwargs)
• fake_ensure · function · L3506-L3509 — def fake_ensure(st)
• fake_exec · function · L3511-L3514 — def fake_exec(st, code, origin, emit, stream=True, language="python")
• test_batched_code_blocks_warn_only_first_ran · function · L3537-L3588 — def test_batched_code_blocks_warn_only_first_ran(monkeypatch, tmp_path)
• fake_chat · function · L3560-L3562 — def fake_chat(messages, cfg, on_delta=None, **kwargs)
• fake_ensure · function · L3564-L3567 — def fake_ensure(st)
• fake_exec · function · L3569-L3572 — def fake_exec(st, code, origin, emit, stream=True, language="python")
• test_effective_api_key_ignores_persisted_placeholder · function · L3591-L3603 — def test_effective_api_key_ignores_persisted_placeholder(tmp_path): # a stub persisted to settings before the config-level filter existed # (e.g. activating a profile seeded with your-api-key-here) must not # make the UI banner report a configured key
• test_llm_cfg_ignores_persisted_placeholder_runtime_key · function · L3606-L3613 — def test_llm_cfg_ignores_persisted_placeholder_runtime_key(tmp_path)
• test_model_profile_mask_and_empty_defaults_ignore_placeholder_keys · function · L3616-L3640 — def test_model_profile_mask_and_empty_defaults_ignore_placeholder_keys(tmp_path)
• test_model_profile_activate_moves_to_front_and_sanitizes_key · function · L3643-L3680 — def test_model_profile_activate_moves_to_front_and_sanitizes_key(tmp_path)
• test_ark_profile_rotation_drops_this_store_datapro_session_and_reconnects · function · L3684-L3772 — def test_ark_profile_rotation_drops_this_store_datapro_session_and_reconnects( tmp_path, monkeypatch )
• _ScopedManager · class · L3691-L3715 — class _ScopedManager
• init · method · L3692-L3695 — def init(self)
• open_session · method · L3697-L3706 — def open_session(self, connector_id, config)
• disconnect · method · L3708-L3715 — def disconnect(self, connector_id, cache_scope=None)
• test_model_routes_invalidate_datapro_only_when_effective_key_changes · function · L3776-L3860 — def test_model_routes_invalidate_datapro_only_when_effective_key_changes( tmp_path, monkeypatch )
• _Manager · class · L3783-L3788 — class _Manager
• init · method · L3784-L3785 — def init(self)
• disconnect · method · L3787-L3788 — def disconnect(self, connector_id, cache_scope=None)
• test_config_provider_switch_never_reuses_old_provider_key_for_datapro · function · L3864-L3910 — def test_config_provider_switch_never_reuses_old_provider_key_for_datapro( tmp_path, monkeypatch )
• _Manager · class · L3871-L3876 — class _Manager
• init · method · L3872-L3873 — def init(self)
• disconnect · method · L3875-L3876 — def disconnect(self, connector_id, cache_scope=None)
• test_inactive_profile_provider_switch_forgets_key_before_ark_activation · function · L3914-L3980 — def test_inactive_profile_provider_switch_forgets_key_before_ark_activation( tmp_path, monkeypatch )
• _Manager · class · L3921-L3926 — class _Manager
• init · method · L3922-L3923 — def init(self)
• disconnect · method · L3925-L3926 — def disconnect(self, connector_id, cache_scope=None)
• test_deleting_active_profile_clears_live_key_and_uses_dedicated_fallback · function · L3984-L4046 — def test_deleting_active_profile_clears_live_key_and_uses_dedicated_fallback( tmp_path, monkeypatch )
• _Manager · class · L3991-L3996 — class _Manager
• init · method · L3992-L3993 — def init(self)
• disconnect · method · L3995-L3996 — def disconnect(self, connector_id, cache_scope=None)
• test_disabling_datapro_disconnects_only_the_current_store_scope · function · L4050-L4089 — def test_disabling_datapro_disconnects_only_the_current_store_scope( tmp_path, monkeypatch )
• _Manager · class · L4057-L4062 — class _Manager
• init · method · L4058-L4059 — def init(self)
• disconnect · method · L4061-L4062 — def disconnect(self, connector_id, cache_scope=None)
• test_connector_editor_patch_preserves_masked_env_and_disconnects_old_process · function · L4093-L4147 — def test_connector_editor_patch_preserves_masked_env_and_disconnects_old_process( tmp_path, monkeypatch )
• _Manager · class · L4098-L4103 — class _Manager
• init · method · L4099-L4100 — def init(self)
• disconnect · method · L4102-L4103 — def disconnect(self, connector_id, cache_scope=None)
• test_local_model_discovery_route_is_explicit_and_non_mutating · function · L4150-L4183 — def test_local_model_discovery_route_is_explicit_and_non_mutating( monkeypatch, tmp_path )
• Discovery · class · L4153-L4160 — class Discovery
• discover · method · L4154-L4160 — def discover(self, *, force=False)
• test_api_unknown_route_returns_error_envelope · function · L4187-L4207 — def test_api_unknown_route_returns_error_envelope(tmp_path)
• test_projects_route_still_answers_an_unparameterized_request_in_full · function · L4210-L4239 — def test_projects_route_still_answers_an_unparameterized_request_in_full(tmp_path)
• test_serializers_expose_dual_id_keys · function · L4242-L4264 — def test_serializers_expose_dual_id_keys(tmp_path)
• test_auto_capture_artifact_created_event_shape · function · L4267-L4284 — def test_auto_capture_artifact_created_event_shape(tmp_path)
• test_edit_rename_upload_artifact_created_shapes · function · L4287-L4327 — def test_edit_rename_upload_artifact_created_shapes(tmp_path)
• _created · function · L4302-L4303 — def _created()
• test_plan_restore_and_delete_artifact_created_shapes · function · L4330-L4377 — def test_plan_restore_and_delete_artifact_created_shapes(tmp_path)
• test_frame_update_status_literal_vocabulary · function · L4380-L4431 — def test_frame_update_status_literal_vocabulary(tmp_path)
• test_auto_title_broadcasts_titled_frame_update · function · L4434-L4468 — def test_auto_title_broadcasts_titled_frame_update(monkeypatch, tmp_path)
• test_token_gate_401_and_cookie_redirect · function · L4471-L4583 — def test_token_gate_401_and_cookie_redirect(monkeypatch, tmp_path, capsys)
• test_gateway_error_maps_to_error_envelope · function · L4586-L4605 — def test_gateway_error_maps_to_error_envelope(tmp_path)
• boom · function · L4598-L4599 — def boom(method, sub)
• test_unhandled_exception_maps_to_500_error_envelope · function · L4608-L4639 — def test_unhandled_exception_maps_to_500_error_envelope(tmp_path, capsys)
• boom · function · L4626-L4627 — def boom(method, sub)
• test_cross_origin_api_write_is_refused · function · L4642-L4660 — def test_cross_origin_api_write_is_refused(tmp_path)
• test_cross_origin_ws_upgrade_is_refused · function · L4663-L4680 — def test_cross_origin_ws_upgrade_is_refused(tmp_path)
• test_ws_upgrade_allows_absent_and_same_origin · function · L4683-L4702 — def test_ws_upgrade_allows_absent_and_same_origin(tmp_path)
• test_dns_rebinding_host_header_is_rejected · function · L4705-L4764 — def test_dns_rebinding_host_header_is_rejected(tmp_path)
• _run · function · L4717-L4730 — def _run(headers, method, path)
• test_execution_log_route_serializer_contract · function · L4767-L4884 — def test_execution_log_route_serializer_contract(tmp_path)
• test_lineage_serializer_producing_cell_and_inputs · function · L4887-L4972 — def test_lineage_serializer_producing_cell_and_inputs(tmp_path)
• test_lineage_serializer_follows_latest_and_restored_version_edges · function · L4975-L5024 — def test_lineage_serializer_follows_latest_and_restored_version_edges(tmp_path)
• test_same_byte_capture_keeps_each_cells_lineage_without_rewriting_the_first · function · L5027-L5102 — def test_same_byte_capture_keeps_each_cells_lineage_without_rewriting_the_first( tmp_path, )
• test_upload_decodes_base64_or_refuses_it · function · L5105-L5169 — def test_upload_decodes_base64_or_refuses_it(tmp_path)
• _bytes · function · L5125-L5126 — def _bytes(res)
• test_ws_encode_frame_length_ladder · function · L5173-L5191 — def test_ws_encode_frame_length_ladder()
• test_ws_read_frame_unmasks_and_roundtrips · function · L5194-L5221 — def test_ws_read_frame_unmasks_and_roundtrips()
• _bytes_handler · function · L5225-L5240 — def _bytes_handler(cfg, runner, hub=None)
• test_serve_artifact_three_way_resolution_and_bytes_contract · function · L5243-L5345 — def test_serve_artifact_three_way_resolution_and_bytes_contract(tmp_path)
• test_stage1_exact_get_rechecks_committed_snapshot_bytes · function · L5348-L5398 — def test_stage1_exact_get_rechecks_committed_snapshot_bytes(tmp_path)
• test_preview_route_forces_html_content_type · function · L5401-L5421 — def test_preview_route_forces_html_content_type(tmp_path)
• test_a_sandbox_grant_is_minted_scoped_and_spendable · function · L5427-L5561 — def test_a_sandbox_grant_is_minted_scoped_and_spendable( tmp_path, app_host, sandbox_host )
• test_sandbox_grant_unavailable_is_an_honest_inert_fallback · function · L5565-L5591 — def test_sandbox_grant_unavailable_is_an_honest_inert_fallback( tmp_path, monkeypatch, reason )
• test_sandbox_preview_verifies_snapshot_and_preserves_html_rendering · function · L5594-L5644 — def test_sandbox_preview_verifies_snapshot_and_preserves_html_rendering( tmp_path, monkeypatch )
• test_send_emits_exactly_one_cache_control_per_response · function · L5647-L5685 — def test_send_emits_exactly_one_cache_control_per_response(tmp_path)
• cache_control · function · L5665-L5668 — def cache_control() -> list[str]
• test_send_serializes_only_the_artifact_security_profile · function · L5688-L5715 — def test_send_serializes_only_the_artifact_security_profile(tmp_path)
• test_every_unprofiled_writer_answers_with_the_same_shell_policy · function · L5718-L5765 — def test_every_unprofiled_writer_answers_with_the_same_shell_policy(tmp_path)
• policies · function · L5740-L5743 — def policies() -> list[str]
• test_an_empty_security_profile_is_not_read_as_no_profile · function · L5768-L5792 — def test_an_empty_security_profile_is_not_read_as_no_profile(tmp_path)
• test_streamed_artifact_bytes_carry_the_same_profile_as_served_ones · function · L5795-L5825 — def test_streamed_artifact_bytes_carry_the_same_profile_as_served_ones(tmp_path)
• test_the_artifact_bundle_route_selects_the_hardened_profile · function · L5828-L5853 — def test_the_artifact_bundle_route_selects_the_hardened_profile(tmp_path)
• test_the_framed_editor_documents_are_the_only_relaxed_static_responses · function · L5856-L5903 — def test_the_framed_editor_documents_are_the_only_relaxed_static_responses(tmp_path)
• profile · function · L5869-L5874 — def profile(path)
• test_upload_without_frame_id_stores_file_but_never_broadcasts · function · L5906-L5931 — def test_upload_without_frame_id_stores_file_but_never_broadcasts(tmp_path)
• test_body_rejects_unparseable_json_with_an_explicit_4xx · function · L5934-L5977 — def test_body_rejects_unparseable_json_with_an_explicit_4xx(tmp_path)
• _with · function · L5952-L5955 — def _with(raw: bytes)
• test_ignored_json_body_is_buffered_before_next_keepalive_request · function · L5980-L5999 — def test_ignored_json_body_is_buffered_before_next_keepalive_request(tmp_path)
• test_request_body_rejects_ambiguous_or_unsupported_framing · function · L6002-L6029 — def test_request_body_rejects_ambiguous_or_unsupported_framing(tmp_path)
• DuplicateLengthHeaders · class · L6021-L6023 — class DuplicateLengthHeaders(dict)
• get_all · method · L6022-L6023 — def get_all(self, name)
• test_request_body_cache_is_released_after_keepalive_dispatch · function · L6032-L6050 — def test_request_body_cache_is_released_after_keepalive_dispatch(tmp_path)
• test_websocket_upgrade_is_never_reused_as_http_keepalive · function · L6053-L6067 — def test_websocket_upgrade_is_never_reused_as_http_keepalive(tmp_path)
• test_kernel_id_labels_default_env_as_python_and_names_switches · function · L6071-L6086 — def test_kernel_id_labels_default_env_as_python_and_names_switches(tmp_path)
• test_persisted_env_roundtrip_and_resume_seeds_new_session · function · L6089-L6118 — def test_persisted_env_roundtrip_and_resume_seeds_new_session(monkeypatch, tmp_path)
• test_notebook_repl_execute_route_gated_by_flag · function · L6122-L6211 — def test_notebook_repl_execute_route_gated_by_flag(monkeypatch, tmp_path)
• test_resolve_env_does_not_clobber_pin_when_env_unresolvable · function · L6214-L6252 — def test_resolve_env_does_not_clobber_pin_when_env_unresolvable(monkeypatch, tmp_path)
• get_environment · function · L6230-L6235 — def get_environment(name)
• test_restart_respawns_when_active_env_is_only_a_pin_fallback · function · L6255-L6289 — def test_restart_respawns_when_active_env_is_only_a_pin_fallback(monkeypatch, tmp_path)
• FallbackKernel · class · L6262-L6267 — class FallbackKernel
• shutdown · method · L6263-L6264 — def shutdown(self)
• restart · method · L6266-L6267 — def restart(self)
• spawn · function · L6273-L6280 — def spawn(state)
• test_restart_still_clears_namespace_when_pin_remains_unavailable · function · L6292-L6328 — def test_restart_still_clears_namespace_when_pin_remains_unavailable( monkeypatch, tmp_path )
• FallbackKernel · class · L6301-L6306 — class FallbackKernel
• restart · method · L6302-L6303 — def restart(self)
• shutdown · method · L6305-L6306 — def shutdown(self)
• unresolved · function · L6313-L6315 — def unresolved(state)
• test_tool_batch_applies_env_switch_before_following_call · function · L6331-L6380 — def test_tool_batch_applies_env_switch_before_following_call(monkeypatch, tmp_path)
• Dispatcher · class · L6339-L6349 — class Dispatcher
• init · method · L6342-L6343 — def init(self, label)
• call · method · L6345-L6349 — def call(self, method, args)
• fake_chat · function · L6360-L6361 — def fake_chat(messages, cfg, on_delta=None, **kwargs)
• apply_pending · function · L6363-L6367 — def apply_pending(state, emit)
• fake_exec · function · L6372-L6374 — def fake_exec(state, code, origin, emit, stream=True, language="python")
• test_env_summary_exposes_canonical_kernel_id · function · L6383-L6397 — def test_env_summary_exposes_canonical_kernel_id(tmp_path)
• test_live_cell_start_event_carries_canonical_kernel_id · function · L6400-L6420 — def test_live_cell_start_event_carries_canonical_kernel_id(monkeypatch, tmp_path)
• test_prose_streamer_hides_nested_tool_example_inside_python_cell · function · L6423-L6445 — def test_prose_streamer_hides_nested_tool_example_inside_python_cell()
• test_kernel_install_route_is_not_gated_by_notebook_repl · function · L6448-L6471 — def test_kernel_install_route_is_not_gated_by_notebook_repl(tmp_path)
• _Recorder · class · L6479-L6491 — class _Recorder
• init · method · L6482-L6485 — def init(self)
• send_json · method · L6487-L6488 — def send_json(self, event)
• replay_begin · method · L6490-L6491 — def replay_begin(self)
• _live_turn · function · L6494-L6498 — def _live_turn(hub, root, count=3)
• test_a_cursor_from_a_previous_daemon_run_is_reported_as_a_gap · function · L6501-L6520 — def test_a_cursor_from_a_previous_daemon_run_is_reported_as_a_gap()
• test_a_restart_is_detected_even_without_a_client_epoch · function · L6523-L6537 — def test_a_restart_is_detected_even_without_a_client_epoch()
• test_an_epochless_cursor_the_counter_has_reached_is_still_a_gap · function · L6540-L6555 — def test_an_epochless_cursor_the_counter_has_reached_is_still_a_gap()
• test_a_cursor_within_the_same_run_replays_only_what_was_missed · function · L6558-L6574 — def test_a_cursor_within_the_same_run_replays_only_what_was_missed()
• test_candidate_resolution_is_kept_in_the_live_resume_window · function · L6577-L6616 — def test_candidate_resolution_is_kept_in_the_live_resume_window()
• test_a_fresh_subscriber_with_no_cursor_is_not_a_gap · function · L6619-L6629 — def test_a_fresh_subscriber_with_no_cursor_is_not_a_gap()
• test_a_cursor_older_than_the_retained_window_is_a_gap · function · L6632-L6644 — def test_a_cursor_older_than_the_retained_window_is_a_gap()
• test_every_hub_instance_has_its_own_epoch · function · L6647-L6648 — def test_every_hub_instance_has_its_own_epoch()
• test_a_stale_cursor_declares_the_gap_without_replaying_anything · function · L6651-L6669 — def test_a_stale_cursor_declares_the_gap_without_replaying_anything()
• test_the_access_token_is_minted_once_and_survives_a_restart · function · L6672-L6700 — def test_the_access_token_is_minted_once_and_survives_a_restart(tmp_path)
• test_token_comparison_is_constant_time_and_refuses_empties · function · L6703-L6714 — def test_token_comparison_is_constant_time_and_refuses_empties()
• test_the_loopback_gate_is_required_by_default · function · L6717-L6758 — def test_the_loopback_gate_is_required_by_default(tmp_path, monkeypatch)
• test_the_cli_presents_the_daemon_credential · function · L6761-L6798 — def test_the_cli_presents_the_daemon_credential(tmp_path, monkeypatch)
• _probe_route · function · L6801-L6814 — def _probe_route(handler_cls, headers, path, method="GET")
• test_a_query_token_bootstraps_only_the_root_page · function · L6817-L6851 — def test_a_query_token_bootstraps_only_the_root_page(tmp_path, monkeypatch)
• test_the_gate_accepts_bearer_and_the_explicit_header · function · L6854-L6902 — def test_the_gate_accepts_bearer_and_the_explicit_header(tmp_path, monkeypatch)
• test_the_correlation_id_reaches_the_job_thread · function · L6905-L6955 — def test_the_correlation_id_reaches_the_job_thread()
• test_every_request_serving_spawn_goes_through_the_helper · function · L6958-L6983 — def test_every_request_serving_spawn_goes_through_the_helper()
• test_a_job_built_outside_a_request_mints_its_own_id_rather_than_none · function · L6986-L7013 — def test_a_job_built_outside_a_request_mints_its_own_id_rather_than_none()
• test_daemon_lifetime_threads_do_not_inherit_a_request_id · function · L7016-L7035 — def test_daemon_lifetime_threads_do_not_inherit_a_request_id()
• test_no_progress_stop_is_a_failed_turn_with_a_stable_code · function · L7038-L7085 — def test_no_progress_stop_is_a_failed_turn_with_a_stable_code(monkeypatch, tmp_path)
• fake_ensure · function · L7054-L7057 — def fake_ensure(st)
• trip · function · L7059-L7063 — def trip(st, emit, visible)
• test_exact_artifact_provenance_routes_keep_the_requested_version · function · L7089-L7179 — def test_exact_artifact_provenance_routes_keep_the_requested_version(tmp_path, surface)
• test_exact_artifact_environment_preserves_missing_historical_metadata · function · L7183-L7219 — def test_exact_artifact_environment_preserves_missing_historical_metadata( tmp_path, imported )
• test_exact_artifact_provenance_rejects_unknown_or_wrong_artifact_version · function · L7224-L7252 — def test_exact_artifact_provenance_rejects_unknown_or_wrong_artifact_version( tmp_path, surface, unknown, )
• test_exact_artifact_provenance_missing_environment_never_uses_live · function · L7255-L7275 — def test_exact_artifact_provenance_missing_environment_never_uses_live(tmp_path)
• test_bytes_route_honours_an_explicit_version_without_latest_fallback · function · L7278-L7311 — def test_bytes_route_honours_an_explicit_version_without_latest_fallback(tmp_path)