← Về thư mục
tests/test_unstarted_worker_admission.py
- _Hub · class · L38-L52 — class _Hub
- init · method · L39-L40 — def init(self) -> None
- emitter · method · L42-L43 — def emitter(self, root_frame_id)
- broadcast · method · L45-L46 — def broadcast(self, root_frame_id, event)
- has_subscriber · method · L48-L49 — def has_subscriber(self, root_frame_id)
- is_running · method · L51-L52 — def is_running(self, root_frame_id)
- _StartFailed · class · L55-L56 — class _StartFailed(RuntimeError)
- runner · function · L60-L68 — def runner(tmp_path)
- frame_id · function · L72-L73 — def frame_id(runner)
- break_worker_start · function · L77-L95 — def break_worker_start(monkeypatch)
- start · function · L87-L92 — def start(self)
- _draft · function · L98-L107 — def _draft(runner, frame_id, status="draft")
- _plan_status · function · L110-L111 — def _plan_status(runner, frame_id)
- assert_session_is_idle · function · L114-L126 — def assert_session_is_idle(runner, frame_id, *, where: str) -> None
- test_a_plan_whose_worker_never_started_leaves_nothing_behind · function · L138-L155 — def test_a_plan_whose_worker_never_started_leaves_nothing_behind( runner, frame_id, break_worker_start, submit, claimed_from )
- test_a_plan_queued_behind_a_running_turn_is_not_stranded · function · L158-L185 — def test_a_plan_queued_behind_a_running_turn_is_not_stranded( runner, frame_id, break_worker_start, monkeypatch )
- test_a_message_whose_worker_never_started_leaves_nothing_behind · function · L193-L200 — def test_a_message_whose_worker_never_started_leaves_nothing_behind( runner, frame_id, break_worker_start )
- test_a_plan_revision_whose_worker_never_started_leaves_nothing_behind · function · L203-L210 — def test_a_plan_revision_whose_worker_never_started_leaves_nothing_behind( runner, frame_id, break_worker_start )
- test_a_repl_whose_worker_never_started_leaves_nothing_behind · function · L213-L220 — def test_a_repl_whose_worker_never_started_leaves_nothing_behind( runner, frame_id, break_worker_start )
- test_the_failure_reaches_the_caller_rather_than_a_202 · function · L223-L231 — def test_the_failure_reaches_the_caller_rather_than_a_202( runner, frame_id, break_worker_start )
- test_a_queued_worker_that_never_started_reads_as_cancelled_not_failed · function · L234-L264 — def test_a_queued_worker_that_never_started_reads_as_cancelled_not_failed( runner, frame_id, break_worker_start )
- _HostileStart · class · L272-L285 — class _HostileStart(RuntimeError)
- str · method · L283-L285 — def str(self) -> str: # type: ignore[override]
- break_worker_start_with · function · L289-L303 — def break_worker_start_with(monkeypatch)
- install · function · L292-L301 — def install(factory)
- start · function · L295-L299 — def start(self)
- test_an_unstarted_job_is_terminalised_not_merely_forgotten · function · L306-L344 — def test_an_unstarted_job_is_terminalised_not_merely_forgotten( runner, frame_id, break_worker_start, monkeypatch )
- spy · function · L323-L325 — def spy(self, result=None, error=None)
- capture · function · L332-L334 — def capture(job, ticket, error, **kwargs)
- test_a_start_failure_that_cannot_be_rendered_still_releases · function · L347-L357 — def test_a_start_failure_that_cannot_be_rendered_still_releases( runner, frame_id, break_worker_start_with )
- test_the_original_start_exception_instance_is_what_propagates · function · L360-L369 — def test_the_original_start_exception_instance_is_what_propagates( runner, frame_id, break_worker_start_with )
- test_a_job_cleanup_fault_still_releases_the_ticket · function · L372-L387 — def test_a_job_cleanup_fault_still_releases_the_ticket( runner, frame_id, break_worker_start, monkeypatch )
- _Hostile · class · L377-L379 — class _Hostile(dict)
- pop · method · L378-L379 — def pop(self, args, *kwargs)
- test_a_plan_rollback_fault_still_releases_the_ticket_and_job · function · L390-L410 — def test_a_plan_rollback_fault_still_releases_the_ticket_and_job( runner, frame_id, break_worker_start, monkeypatch )
- boom · function · L399-L400 — def boom(args, *kwargs)
- test_a_hub_emit_fault_does_not_leak_the_coordinator_maps · function · L413-L433 — def test_a_hub_emit_fault_does_not_leak_the_coordinator_maps(runner, frame_id)
- boom · function · L419-L420 — def boom(root_frame_id, event)