tests/test_public_exception_projector.py

• CanaryFailure · class · L76-L83 — class CanaryFailure(RuntimeError)
• init · method · L79-L83 — def init(self) -> None
• assert_safe · function · L86-L98 — def assert_safe(body, *, expect_code: str | None = None) -> None
• _Hub · class · L101-L115 — class _Hub
• init · method · L102-L103 — def init(self) -> None
• emitter · method · L105-L106 — def emitter(self, root_frame_id)
• broadcast · method · L108-L109 — def broadcast(self, root_frame_id, event)
• has_subscriber · method · L111-L112 — def has_subscriber(self, root_frame_id)
• drop_frame · method · L114-L115 — def drop_frame(self, root_frame_id)
• _on_a_request_thread · function · L119-L127 — def _on_a_request_thread()
• runner · function · L131-L141 — def runner(tmp_path)
• frame_id · function · L145-L146 — def frame_id(runner)
• _handler · function · L149-L162 — def _handler(runner)
• _last_json · function · L165-L167 — def _last_json(sent)
• _request_headers · function · L170-L179 — def _request_headers(runner)
• test_an_unknown_route_exception_is_answered_generically · function · L187-L208 — def test_an_unknown_route_exception_is_answered_generically(runner, monkeypatch)
• test_a_deliberate_gateway_error_keeps_the_message_someone_wrote · function · L211-L235 — def test_a_deliberate_gateway_error_keeps_the_message_someone_wrote( runner, monkeypatch )
• test_a_failed_turn_leaks_on_neither_the_socket_nor_the_job_result · function · L243-L269 — def test_a_failed_turn_leaks_on_neither_the_socket_nor_the_job_result( runner, frame_id, monkeypatch )
• test_a_failed_plan_job_reports_generically · function · L277-L290 — def test_a_failed_plan_job_reports_generically(runner, frame_id, monkeypatch)
• test_a_repl_job_that_throws_around_the_cell_reports_generically · function · L298-L310 — def test_a_repl_job_that_throws_around_the_cell_reports_generically( runner, frame_id, monkeypatch )
• test_a_failing_connector_answers_a_real_status_not_200 · function · L319-L356 — def test_a_failing_connector_answers_a_real_status_not_200(runner, monkeypatch)
• _Manager · class · L337-L339 — class _Manager
• call_tool · method · L338-L339 — def call_tool(self, a, *k)
• test_a_remote_compute_refresh_failure_never_quotes_the_provider · function · L364-L388 — def test_a_remote_compute_refresh_failure_never_quotes_the_provider( runner, frame_id, monkeypatch )
• _Compute · class · L372-L374 — class _Compute
• result · method · L373-L374 — def result(self, a, *k)
• test_the_diagnostic_keeps_the_failure_but_redacts_the_credential · function · L396-L424 — def test_the_diagnostic_keeps_the_failure_but_redacts_the_credential()
• test_no_path_of_any_kind_reaches_the_diagnostic · function · L427-L452 — def test_no_path_of_any_kind_reaches_the_diagnostic(monkeypatch, tmp_path)
• test_the_projector_falls_back_to_the_local_correlation_id · function · L460-L471 — def test_the_projector_falls_back_to_the_local_correlation_id()
• _secret_scanner · function · L479-L496 — def _secret_scanner()
• test_the_credential_canary_is_still_shaped_like_a_real_key · function · L499-L515 — def test_the_credential_canary_is_still_shaped_like_a_real_key(tmp_path)
• test_this_file_carries_no_value_the_release_gate_would_flag · function · L518-L530 — def test_this_file_carries_no_value_the_release_gate_would_flag()
• test_a_restore_that_fails_in_the_filesystem_does_not_quote_the_path · function · L538-L565 — def test_a_restore_that_fails_in_the_filesystem_does_not_quote_the_path(runner)
• explode · function · L547-L548 — def explode(self, args, *kwargs)
• test_a_restore_refusal_this_project_wrote_still_reaches_the_user · function · L568-L594 — def test_a_restore_refusal_this_project_wrote_still_reaches_the_user(runner)
• refuse · function · L577-L578 — def refuse(self, args, *kwargs)
• test_an_unreadable_attachment_card_names_the_file_and_nothing_else · function · L597-L629 — def test_an_unreadable_attachment_card_names_the_file_and_nothing_else()
• unreadable · function · L607-L608 — def unreadable(self, args, *kwargs)
• test_a_failed_kernel_restart_does_not_quote_the_path_it_tried · function · L632-L665 — def test_a_failed_kernel_restart_does_not_quote_the_path_it_tried(runner, monkeypatch)
• refuse · function · L646-L647 — def refuse(args, *kwargs)
• test_an_execution_attempt_carries_no_exception_text_at_all · function · L675-L712 — def test_an_execution_attempt_carries_no_exception_text_at_all(tmp_path)
• _Ports · class · L694-L696 — class _Ports
• finish_attempt · method · L695-L696 — def finish_attempt(self, attempt_id, terminal_state, payload)
• test_an_execution_attempt_hides_a_foreign_path_and_a_command · function · L715-L736 — def test_an_execution_attempt_hides_a_foreign_path_and_a_command(tmp_path)
• _Ports · class · L721-L723 — class _Ports
• finish_attempt · method · L722-L723 — def finish_attempt(self, attempt_id, terminal_state, payload)
• _api · function · L756-L768 — def _api(runner, method, path, body=None)
• _failed_frame_updates · function · L771-L776 — def _failed_frame_updates(runner)
• _run_failing_turn · function · L779-L797 — def _run_failing_turn(runner, monkeypatch, exc, *, request="go")
• boom · function · L783-L784 — def boom(_a, *_k)
• test_one_id_reaches_all_five_surfaces_for_a_real_internal_failure · function · L801-L842 — def test_one_id_reaches_all_five_surfaces_for_a_real_internal_failure( runner, monkeypatch )
• test_ark_burst_protection_is_named_consistently_without_blaming_the_key · function · L846-L888 — def test_ark_burst_protection_is_named_consistently_without_blaming_the_key( runner, monkeypatch )
• test_a_max_turns_failure_is_named_too · function · L892-L928 — def test_a_max_turns_failure_is_named_too(runner, monkeypatch)
• test_the_retry_veto_reaches_the_surface_that_offers_the_retry · function · L932-L953 — def test_the_retry_veto_reaches_the_surface_that_offers_the_retry(runner, monkeypatch)
• test_an_ordinary_failure_makes_no_claim_about_committed_output · function · L957-L967 — def test_an_ordinary_failure_makes_no_claim_about_committed_output(runner, monkeypatch)
• test_no_canary_survives_on_any_of_the_five_surfaces · function · L971-L993 — def test_no_canary_survives_on_any_of_the_five_surfaces(runner, monkeypatch)
• test_the_operator_diagnostic_is_written_exactly_once · function · L997-L1024 — def test_the_operator_diagnostic_is_written_exactly_once(runner, monkeypatch)
• recording · function · L1013-L1015 — def recording(exc, *, surface, request_id=None)
• test_a_plan_approval_failure_is_named_on_its_own_route · function · L1028-L1064 — def test_a_plan_approval_failure_is_named_on_its_own_route(runner, monkeypatch)
• boom · function · L1047-L1048 — def boom(_a, *_k)
• test_an_outer_message_failure_is_persisted_and_projected · function · L1080-L1117 — def test_an_outer_message_failure_is_persisted_and_projected(runner, monkeypatch)
• test_an_outer_plan_failure_is_persisted_and_projected · function · L1121-L1170 — def test_an_outer_plan_failure_is_persisted_and_projected(runner, monkeypatch)
• test_an_outer_failure_records_exactly_one_diagnostic · function · L1174-L1203 — def test_an_outer_failure_records_exactly_one_diagnostic(runner, monkeypatch)
• _committed_then_tail_failure · function · L1222-L1260 — def _committed_then_tail_failure(runner, monkeypatch)
• loop_boom · function · L1226-L1232 — def loop_boom(_a, *_k)
• tail_boom · function · L1239-L1242 — def tail_boom(args, *kwargs)
• loop_then_mark · function · L1246-L1250 — def loop_then_mark(args, *kwargs)
• test_a_tail_failure_does_not_downgrade_the_retry_veto · function · L1264-L1276 — def test_a_tail_failure_does_not_downgrade_the_retry_veto(runner, monkeypatch)
• test_a_double_fault_leaves_exactly_one_terminal_failure · function · L1280-L1303 — def test_a_double_fault_leaves_exactly_one_terminal_failure(runner, monkeypatch)
• test_a_double_fault_records_both_diagnostics_once_each · function · L1307-L1323 — def test_a_double_fault_records_both_diagnostics_once_each(runner, monkeypatch)
• test_a_second_projection_cannot_un_say_the_veto · function · L1327-L1350 — def test_a_second_projection_cannot_un_say_the_veto(runner)
• test_the_terminal_failure_handoff_is_scoped_to_its_turn · function · L1354-L1381 — def test_the_terminal_failure_handoff_is_scoped_to_its_turn(runner)
• test_the_outer_handler_actually_receives_the_note · function · L1385-L1404 — def test_the_outer_handler_actually_receives_the_note(runner, monkeypatch)
• test_an_outer_plan_failure_records_exactly_one_diagnostic · function · L1408-L1443 — def test_an_outer_plan_failure_records_exactly_one_diagnostic(runner, monkeypatch)
• test_an_outer_failure_after_a_committed_turn_keeps_the_veto_everywhere · function · L1447-L1463 — def test_an_outer_failure_after_a_committed_turn_keeps_the_veto_everywhere( runner, monkeypatch )
• test_a_reused_request_id_does_not_let_one_turn_amend_another · function · L1467-L1524 — def test_a_reused_request_id_does_not_let_one_turn_amend_another(runner, monkeypatch)
• post · function · L1481-L1496 — def post(body): # The id a client supplied, twice. MessageJob reads the contextvar, # so this is where a reused X-Request-Id actually lands.
• test_a_store_that_cannot_persist_still_completes_the_job · function · L1528-L1567 — def test_a_store_that_cannot_persist_still_completes_the_job(runner, monkeypatch)
• unwritable · function · L1543-L1544 — def unwritable(_a, *_k)
• test_a_failed_persistence_does_not_add_a_second_diagnostic · function · L1571-L1600 — def test_a_failed_persistence_does_not_add_a_second_diagnostic(runner, monkeypatch)
• test_an_outer_plan_failure_lands_on_the_branch_it_was_submitted_on · function · L1604-L1659 — def test_an_outer_plan_failure_lands_on_the_branch_it_was_submitted_on( runner, monkeypatch )
• _outer_failure_with_unwritable_frame · function · L1662-L1714 — def _outer_failure_with_unwritable_frame(runner, monkeypatch, *, plan: bool)
• refuse · function · L1703-L1706 — def refuse(fid, **fields)
• test_a_frame_status_write_failure_does_not_swallow_the_terminal_event · function · L1719-L1741 — def test_a_frame_status_write_failure_does_not_swallow_the_terminal_event( runner, monkeypatch, plan )
• test_an_outer_message_failure_lands_on_the_branch_it_was_submitted_on · function · L1745-L1780 — def test_an_outer_message_failure_lands_on_the_branch_it_was_submitted_on( runner, monkeypatch )
• test_the_processing_event_names_the_turn_it_starts · function · L1784-L1807 — def test_the_processing_event_names_the_turn_it_starts(runner, monkeypatch)
• test_a_direct_turn_still_names_itself · function · L1811-L1833 — def test_a_direct_turn_still_names_itself(runner, monkeypatch)
• test_a_direct_submit_names_one_turn_everywhere · function · L1845-L1862 — def test_a_direct_submit_names_one_turn_everywhere(runner, monkeypatch)
• test_a_direct_plan_turn_names_one_turn_everywhere · function · L1866-L1891 — def test_a_direct_plan_turn_names_one_turn_everywhere(runner, monkeypatch)
• test_a_direct_plan_failure_names_one_turn_everywhere · function · L1895-L1930 — def test_a_direct_plan_failure_names_one_turn_everywhere(runner, monkeypatch)
• test_a_plan_failure_before_the_turn_starts_still_names_an_execution · function · L1934-L1965 — def test_a_plan_failure_before_the_turn_starts_still_names_an_execution( runner, monkeypatch )
• test_a_plan_tail_failure_names_the_execution_the_turn_actually_ran · function · L1969-L2013 — def test_a_plan_tail_failure_names_the_execution_the_turn_actually_ran( runner, monkeypatch )
• run_then_fail · function · L1991-L1993 — def run_then_fail(args, *kwargs)
• hub · function · L2042-L2045 — def hub()
• _live · function · L2048-L2049 — def _live(hub, frame_id)
• test_a_new_execution_takes_the_window_over_from_a_running_one · function · L2052-L2075 — def test_a_new_execution_takes_the_window_over_from_a_running_one(hub)
• test_an_idless_reset_keeps_the_identity_the_boundary_established · function · L2078-L2098 — def test_an_idless_reset_keeps_the_identity_the_boundary_established(hub)
• test_every_late_event_from_the_previous_execution_is_dropped · function · L2101-L2139 — def test_every_late_event_from_the_previous_execution_is_dropped(hub)
• test_the_running_executions_own_terminal_still_closes_the_window · function · L2142-L2163 — def test_the_running_executions_own_terminal_still_closes_the_window(hub)
• test_a_daemon_without_execution_ids_behaves_as_it_always_did · function · L2166-L2173 — def test_a_daemon_without_execution_ids_behaves_as_it_always_did(hub)
• test_a_late_turn_does_not_end_the_resume_window_of_the_running_one · function · L2177-L2347 — def test_a_late_turn_does_not_end_the_resume_window_of_the_running_one(tmp_path)
• loop · function · L2226-L2233 — def loop(_st, _a, *_k)
• tail · function · L2237-L2241 — def tail(args, *kwargs)
• persist_holding_the_lease · function · L2245-L2249 — def persist_holding_the_lease(args, *kwargs)
• test_a_plan_202_names_the_execution_a_pre_run_failure_will_use · function · L2355-L2392 — def test_a_plan_202_names_the_execution_a_pre_run_failure_will_use( runner, monkeypatch, path, body )
• test_a_post_run_plan_failure_reports_the_real_execution_on_every_surface · function · L2396-L2432 — def test_a_post_run_plan_failure_reports_the_real_execution_on_every_surface( runner, monkeypatch )
• run_then_fail · function · L2413-L2415 — def run_then_fail(args, *kwargs)
• _FakeConn · class · L2438-L2456 — class _FakeConn
• init · method · L2441-L2444 — def init(self) -> None
• send_json · method · L2446-L2447 — def send_json(self, obj: dict) -> None
• refresh_visibility · method · L2452-L2453 — def refresh_visibility(self, root_frame_id)
• may_receive · method · L2455-L2456 — def may_receive(self, root_frame_id)
• _turn_events · function · L2459-L2464 — def _turn_events(conn)
• test_a_late_turns_events_never_reach_a_subscriber · function · L2467-L2515 — def test_a_late_turns_events_never_reach_a_subscriber(hub)
• test_state_deltas_that_no_execution_owns_are_still_broadcast · function · L2518-L2543 — def test_state_deltas_that_no_execution_owns_are_still_broadcast(hub)
• test_the_running_turns_own_terminal_still_reaches_the_socket · function · L2546-L2570 — def test_the_running_turns_own_terminal_still_reaches_the_socket(hub)
• test_a_daemon_that_names_no_execution_broadcasts_everything · function · L2573-L2585 — def test_a_daemon_that_names_no_execution_broadcasts_everything(hub)
• test_a_tab_that_joins_during_b_is_never_told_that_a_ended_it · function · L2588-L2636 — def test_a_tab_that_joins_during_b_is_never_told_that_a_ended_it(hub)
• test_a_failed_turn_leaves_its_ticket_marked_failed · function · L2643-L2671 — def test_a_failed_turn_leaves_its_ticket_marked_failed(runner, monkeypatch)
• test_a_turn_is_still_running_while_its_failure_is_being_recorded · function · L2675-L2712 — def test_a_turn_is_still_running_while_its_failure_is_being_recorded( runner, monkeypatch )
• watch · function · L2690-L2696 — def watch(root_frame_id, job, message): # Inside the lease, in the OUTER handler -- the one that owns # job.finish. An inner failure never reaches here, so the fault has # to leave run_message itself for this window to exist at all.
• test_an_outer_failure_leaves_exactly_one_terminal_and_it_is_failed · function · L2716-L2744 — def test_an_outer_failure_leaves_exactly_one_terminal_and_it_is_failed( runner, monkeypatch )
• _draft · function · L2750-L2759 — def _draft(runner, frame_id, status="draft")
• _plan_status · function · L2762-L2763 — def _plan_status(runner, frame_id)
• test_a_plan_that_fails_before_it_runs_does_not_stay_executing · function · L2771-L2811 — def test_a_plan_that_fails_before_it_runs_does_not_stay_executing( runner, monkeypatch, action, claimed_from )
• test_a_cancelled_plan_turn_settles_paused_not_failed · function · L2819-L2846 — def test_a_cancelled_plan_turn_settles_paused_not_failed( runner, monkeypatch, action, claimed_from, expected )
• test_a_plan_202_names_a_real_coordinator_execution · function · L2850-L2903 — def test_a_plan_202_names_a_real_coordinator_execution(runner)
• blocking_loop · function · L2863-L2866 — def blocking_loop(_a, *_k)
• test_a_finalising_plan_turn_still_owns_the_session · function · L2907-L2979 — def test_a_finalising_plan_turn_still_owns_the_session(runner)
• emit_ready · function · L2930-L2936 — def emit_ready(emit, rid, plan)
• loop · function · L2938-L2944 — def loop(_st, _a, *_k)
• test_a_failure_after_the_plan_finished_does_not_rewrite_its_status · function · L2983-L3023 — def test_a_failure_after_the_plan_finished_does_not_rewrite_its_status( runner, monkeypatch )
• emit_ready · function · L3004-L3011 — def emit_ready(emit, rid, plan)
• test_a_plan_cancelled_while_still_queued_does_not_strand_its_claim · function · L3027-L3073 — def test_a_plan_cancelled_while_still_queued_does_not_strand_its_claim(runner)
• loop · function · L3046-L3049 — def loop(_a, *_k)
• test_a_failing_plan_turn_owns_the_session_while_it_settles · function · L3077-L3149 — def test_a_failing_plan_turn_owns_the_session_while_it_settles(runner)
• loop · function · L3101-L3105 — def loop(_a, *_k)
• settle_holding_the_lease · function · L3109-L3113 — def settle_holding_the_lease(args, *kwargs)