tests/test_producer_output_budgets.py

• offline_worker · function · L46-L61 — def offline_worker(monkeypatch)
• test_a_cell_writing_200mb_to_stderr_does_not_allocate_200mb · function · L64-L92 — def test_a_cell_writing_200mb_to_stderr_does_not_allocate_200mb(offline_worker)
• _chained_failure · function · L95-L102 — def _chained_failure(depth: int, message: str) -> None
• test_a_large_traceback_is_bounded_while_it_is_formatted · function · L105-L135 — def test_a_large_traceback_is_bounded_while_it_is_formatted()
• test_a_traceback_that_fits_carries_no_marker · function · L138-L151 — def test_a_traceback_that_fits_carries_no_marker()
• test_a_huge_exception_message_still_produces_a_response_frame · function · L154-L169 — def test_a_huge_exception_message_still_produces_a_response_frame(offline_worker)
• test_a_trapped_system_exit_message_is_bounded_too · function · L172-L183 — def test_a_trapped_system_exit_message_is_bounded_too(offline_worker)
• test_the_bounded_buffer_reports_the_length_it_was_handed · function · L186-L205 — def test_the_bounded_buffer_reports_the_length_it_was_handed()
• test_a_buffer_that_was_never_cut_says_nothing · function · L208-L212 — def test_a_buffer_that_was_never_cut_says_nothing()
• test_stdout_is_still_streamed_and_bounded_through_the_shared_base · function · L215-L238 — def test_stdout_is_still_streamed_and_bounded_through_the_shared_base(monkeypatch)
• _BlockedKernel · class · L244-L262 — class _BlockedKernel
• init · method · L247-L248 — def init(self) -> None
• execute · method · L250-L253 — def execute(self, code, origin="agent", on_chunk=None)
• interrupt · method · L255-L256 — def interrupt(self) -> None
• kill_worker · method · L258-L259 — def kill_worker(self) -> None
• shutdown · method · L261-L262 — def shutdown(self) -> None
• test_a_background_slot_is_claimed_before_the_kernel_is_created · function · L265-L301 — def test_a_background_slot_is_claimed_before_the_kernel_is_created()
• factory · function · L277-L283 — def factory() -> _BlockedKernel: # At the instant a worker would be spawned, this job is already in the # registry — the slot is claimed, not merely intended.
• test_a_spawn_failure_returns_the_slot_it_claimed · function · L304-L320 — def test_a_spawn_failure_returns_the_slot_it_claimed()
• factory · function · L313-L314 — def factory()
• test_the_r_worker_bounds_are_derived_from_the_python_ones · function · L326-L346 — def test_the_r_worker_bounds_are_derived_from_the_python_ones()
• test_the_r_error_message_is_capped_at_the_producer · function · L350-L378 — def test_the_r_error_message_is_capped_at_the_producer()
• test_real_r_caps_a_giant_error_instead_of_wiring_it · function · L382-L408 — def test_real_r_caps_a_giant_error_instead_of_wiring_it(tmp_path)
• test_the_host_sink_cap_is_the_python_workers_cap · function · L414-L422 — def test_the_host_sink_cap_is_the_python_workers_cap()
• test_the_host_drain_counts_every_byte_it_declines_to_keep · function · L425-L477 — def test_the_host_drain_counts_every_byte_it_declines_to_keep()
• test_the_host_drain_streams_before_the_producer_pauses · function · L480-L520 — def test_the_host_drain_streams_before_the_producer_pauses()
• test_the_host_drain_does_not_split_a_character_across_two_reads · function · L523-L558 — def test_the_host_drain_does_not_split_a_character_across_two_reads()
• test_one_r_expression_cannot_outrun_the_host_cap · function · L562-L608 — def test_one_r_expression_cannot_outrun_the_host_cap(tmp_path)
• test_the_r_message_stream_is_bounded_by_the_same_drain · function · L612-L637 — def test_the_r_message_stream_is_bounded_by_the_same_drain(tmp_path)
• test_a_finished_r_cell_does_not_wait_out_the_drain_grace · function · L641-L670 — def test_a_finished_r_cell_does_not_wait_out_the_drain_grace(tmp_path)
• test_the_stdout_truncation_flag_is_exact_at_the_cap · function · L686-L707 — def test_the_stdout_truncation_flag_is_exact_at_the_cap(tmp_path, size, truncated)
• test_the_stderr_truncation_flag_is_exact_at_the_cap · function · L715-L732 — def test_the_stderr_truncation_flag_is_exact_at_the_cap(tmp_path, size, truncated)
• test_a_multibyte_character_cut_by_the_cap_is_still_reported_truncated · function · L736-L755 — def test_a_multibyte_character_cut_by_the_cap_is_still_reported_truncated(tmp_path)
• test_an_interrupted_cell_reports_what_the_host_had_drained · function · L759-L815 — def test_an_interrupted_cell_reports_what_the_host_had_drained(tmp_path)
• interrupt_once_streaming · function · L789-L794 — def interrupt_once_streaming(_text: str) -> None: # Exactly one SIGINT: the drain can keep delivering chunks after # the first, and a second signal could land between cells.
• test_r_top_level_fallback_preserves_host_capture · function · L852-L923 — def test_r_top_level_fallback_preserves_host_capture( tmp_path, raise_condition, expected_error, interrupted )
• test_r_top_level_fallback_cannot_halt_rscript_or_hang_the_host · function · L928-L999 — def test_r_top_level_fallback_cannot_halt_rscript_or_hang_the_host( tmp_path, failing_helper )
• run · function · L973-L977 — def run() -> None
• test_an_interrupt_escaping_oai4s_run_still_reports_the_host_capture · function · L1003-L1046 — def test_an_interrupt_escaping_oai4s_run_still_reports_the_host_capture(tmp_path)
• test_the_kernel_stderr_tail_is_bounded_in_bytes_not_lines · function · L1052-L1078 — def test_the_kernel_stderr_tail_is_bounded_in_bytes_not_lines()
• test_the_stderr_tail_keeps_the_end_and_reports_an_untruncated_read · function · L1081-L1094 — def test_the_stderr_tail_keeps_the_end_and_reports_an_untruncated_read()
• test_the_drain_reads_the_raw_pipe_so_the_budget_is_in_real_bytes · function · L1097-L1137 — def test_the_drain_reads_the_raw_pipe_so_the_budget_is_in_real_bytes()
• test_the_spawn_wires_the_drain_to_the_raw_pipe · function · L1140-L1175 — def test_the_spawn_wires_the_drain_to_the_raw_pipe()