tests/test_plan_resume_claim.py

• _Hub · class · L26-L47 — class _Hub
• init · method · L29-L30 — def init(self) -> None
• emitter · method · L32-L37 — def emitter(self, root_frame_id)
• emit · function · L33-L35 — def emit(event)
• broadcast · method · L39-L40 — def broadcast(self, root_frame_id, event)
• has_subscriber · method · L42-L44 — def has_subscriber(self, root_frame_id)
• drop_frame · method · L46-L47 — def drop_frame(self, root_frame_id)
• _free_port · function · L50-L53 — def _free_port() -> int
• _paused_plan · function · L56-L72 — def _paused_plan(store, frame_id)
• test_two_concurrent_resume_posts_start_exactly_one_turn · function · L75-L185 — def test_two_concurrent_resume_posts_start_exactly_one_turn(tmp_path)
• _run_message · function · L100-L107 — def _run_message(root_frame_id, project_id, seed, model, plan=False)
• _synchronised_lookup · function · L120-L130 — def _synchronised_lookup(fid)
• _resume · function · L140-L157 — def _resume()
• test_the_claim_is_the_update_itself_not_a_status_read · function · L188-L226 — def test_the_claim_is_the_update_itself_not_a_status_read(tmp_path)
• test_a_resume_that_wins_the_claim_still_reports_per_status_refusals · function · L229-L269 — def test_a_resume_that_wins_the_claim_still_reports_per_status_refusals(tmp_path)
• _draft_plan · function · L277-L293 — def _draft_plan(store, frame_id)
• test_two_concurrent_approve_posts_start_exactly_one_turn · function · L296-L408 — def test_two_concurrent_approve_posts_start_exactly_one_turn(tmp_path)
• _run_message · function · L324-L331 — def _run_message(root_frame_id, project_id, seed, model, plan=False)
• _synchronised_lookup · function · L343-L353 — def _synchronised_lookup(fid)
• _approve · function · L363-L380 — def _approve()
• test_the_approval_claim_reports_per_status_refusals · function · L411-L445 — def test_the_approval_claim_reports_per_status_refusals(tmp_path)
• _route_handler · function · L453-L461 — def _route_handler(cfg, runner)
• test_a_job_that_never_starts_releases_the_claim · function · L471-L518 — def test_a_job_that_never_starts_releases_the_claim( tmp_path, action, submit_attr, seed )
• test_shutdown_survives_a_job_whose_thread_never_started · function · L521-L563 — def test_shutdown_survives_a_job_whose_thread_never_started(tmp_path)
• _Live · class · L543-L545 — class _Live(threading.Thread)
• run · method · L544-L545 — def run(self)