← Về thư mục
tests/test_background_cleanup.py
- _HungKernel · class · L17-L39 — class _HungKernel
- init · method · L18-L23 — def init(self) -> None
- execute · method · L25-L29 — def execute(self, code, origin="agent", on_chunk=None)
- interrupt · method · L31-L32 — def interrupt(self)
- kill_worker · method · L34-L36 — def kill_worker(self)
- shutdown · method · L38-L39 — def shutdown(self)
- test_shutdown_interrupts_then_kills_hung_background_workers · function · L42-L54 — def test_shutdown_interrupts_then_kills_hung_background_workers()
- test_background_admission_lease_spans_the_worker_lifetime · function · L57-L83 — def test_background_admission_lease_spans_the_worker_lifetime()
- test_background_writer_gate_spans_lifetime_when_capture_is_disabled · function · L86-L114 — def test_background_writer_gate_spans_lifetime_when_capture_is_disabled()
- test_malformed_background_admission_refuses_before_kernel_creation · function · L117-L134 — def test_malformed_background_admission_refuses_before_kernel_creation()
- kernel_factory · function · L120-L123 — def kernel_factory()
- test_background_thread_start_failure_releases_capture_admission · function · L137-L164 — def test_background_thread_start_failure_releases_capture_admission(monkeypatch)
- CannotStart · class · L141-L146 — class CannotStart
- init · method · L142-L143 — def init(self, args, *kwargs)
- start · method · L145-L146 — def start(self)
- test_background_base_exception_has_terminal_public_state_and_reuses_slot · function · L167-L223 — def test_background_base_exception_has_terminal_public_state_and_reuses_slot()
- InterruptingKernel · class · L170-L179 — class InterruptingKernel
- init · method · L171-L172 — def init(self) -> None
- execute · method · L174-L176 — def execute(self, code, origin="agent", on_chunk=None)
- shutdown · method · L178-L179 — def shutdown(self)
- SuccessfulKernel · class · L181-L187 — class SuccessfulKernel
- execute · method · L182-L184 — def execute(self, code, origin="agent", on_chunk=None)
- shutdown · method · L186-L187 — def shutdown(self)
- test_background_shutdown_base_exception_still_releases_admission · function · L226-L253 — def test_background_shutdown_base_exception_still_releases_admission()
- BrokenShutdownKernel · class · L229-L235 — class BrokenShutdownKernel
- execute · method · L230-L232 — def execute(self, code, origin="agent", on_chunk=None)
- shutdown · method · L234-L235 — def shutdown(self)
- test_executor_shutdown_does_not_skip_a_job_blocked_in_cleanup · function · L256-L316 — def test_executor_shutdown_does_not_skip_a_job_blocked_in_cleanup()
- CleanupBlockingKernel · class · L263-L282 — class CleanupBlockingKernel
- init · method · L264-L266 — def init(self) -> None
- execute · method · L268-L270 — def execute(self, code, origin="agent", on_chunk=None)
- shutdown · method · L272-L275 — def shutdown(self)
- interrupt · method · L277-L278 — def interrupt(self)
- kill_worker · method · L280-L282 — def kill_worker(self)
- Lifetime · class · L284-L290 — class Lifetime
- enter · method · L285-L286 — def enter(self)
- exit · method · L288-L290 — def exit(self, exc_type, exc, traceback)
- test_external_mutation_is_reentrant_but_exclusive_with_writers · function · L319-L346 — def test_external_mutation_is_reentrant_but_exclusive_with_writers()
- test_external_and_background_writers_remain_exclusive_when_capture_is_disabled · function · L349-L368 — def test_external_and_background_writers_remain_exclusive_when_capture_is_disabled()
- test_external_mutation_rejects_a_different_owner_thread · function · L371-L398 — def test_external_mutation_rejects_a_different_owner_thread()
- hold_mutation · function · L377-L384 — def hold_mutation() -> None
- test_external_mutation_release_corruption_poisons_all_later_admission · function · L401-L417 — def test_external_mutation_release_corruption_poisons_all_later_admission()
- test_capture_release_corruption_does_not_mask_and_permanently_fails_closed · function · L420-L439 — def test_capture_release_corruption_does_not_mask_and_permanently_fails_closed()
- test_malformed_capture_state_fails_closed_before_admission · function · L457-L475 — def test_malformed_capture_state_fails_closed_before_admission( captures, owner, backgrounds )
- test_a_background_cell_buffer_does_not_grow_without_bound · function · L478-L508 — def test_a_background_cell_buffer_does_not_grow_without_bound()
- _UninterruptibleKernel · class · L511-L524 — class _UninterruptibleKernel(_HungKernel)
- interrupt · method · L519-L524 — def interrupt(self)
- test_a_stop_that_reached_nobody_is_reported_to_the_caller · function · L527-L545 — def test_a_stop_that_reached_nobody_is_reported_to_the_caller()
- test_a_delivered_stop_adds_no_undelivered_note · function · L548-L567 — def test_a_delivered_stop_adds_no_undelivered_note()
- _StoppableKernel · class · L552-L556 — class _StoppableKernel(_HungKernel)
- interrupt · method · L553-L556 — def interrupt(self)
- test_a_kernel_that_makes_no_delivery_claim_is_not_reported_as_failed · function · L570-L585 — def test_a_kernel_that_makes_no_delivery_claim_is_not_reported_as_failed()