tests/test_delegation_runtime.py

• _submitted · function · L38-L46 — def _submitted(output=None)
• _wait_for · function · L49-L55 — def _wait_for(predicate, timeout: float = 2.0) -> None
• test_delegated_agent_writes_its_own_canonical_ledger · function · L58-L103 — def test_delegated_agent_writes_its_own_canonical_ledger(monkeypatch)
• finalize_chat · function · L64-L84 — def finalize_chat(messages, cfg, **kwargs)
• test_nested_runners_share_one_tree_budget_and_stats · function · L106-L138 — def test_nested_runners_share_one_tree_budget_and_stats(monkeypatch)
• fake_run · function · L109-L115 — def fake_run(self, task)
• test_trusted_capture_rejects_parallel_delegation_before_reservation · function · L148-L163 — def test_trusted_capture_rejects_parallel_delegation_before_reservation( delegation_spec, )
• test_trusted_capture_keeps_single_synchronous_delegation · function · L166-L178 — def test_trusted_capture_keeps_single_synchronous_delegation(monkeypatch)
• test_trusted_capture_rejects_a_second_thread_before_reservation · function · L181-L213 — def test_trusted_capture_rejects_a_second_thread_before_reservation(monkeypatch)
• held_run · function · L185-L188 — def held_run(self, task)
• test_trusted_capture_gate_is_reentrant_for_synchronous_descendants · function · L216-L240 — def test_trusted_capture_gate_is_reentrant_for_synchronous_descendants(monkeypatch)
• nested_run · function · L219-L226 — def nested_run(self, task)
• test_trusted_capture_child_cannot_start_a_background_kernel · function · L243-L277 — def test_trusted_capture_child_cannot_start_a_background_kernel(monkeypatch)
• inspect_policy · function · L246-L254 — def inspect_policy(self, task)
• test_shared_budget_reservation_is_atomic_across_concurrent_runners · function · L280-L341 — def test_shared_budget_reservation_is_atomic_across_concurrent_runners(monkeypatch)
• spawn · function · L290-L299 — def spawn(runner, index)
• test_depth_four_is_an_unconditional_leaf · function · L344-L364 — def test_depth_four_is_an_unconditional_leaf(monkeypatch)
• fake_run · function · L347-L355 — def fake_run(self, task)
• _FakeKernel · class · L367-L402 — class _FakeKernel
• init · method · L373-L377 — def init(self, args, *kwargs)
• enter · method · L379-L380 — def enter(self)
• exit · method · L382-L383 — def exit(self, *args)
• execute · method · L385-L398 — def execute(self, code, **kwargs)
• interrupt · method · L400-L402 — def interrupt(self)
• _reset_fake_kernel · function · L405-L409 — def _reset_fake_kernel(*, block_actions: bool) -> None
• test_stop_child_interrupts_exact_foreground_kernel_and_engine_cancels · function · L412-L450 — def test_stop_child_interrupts_exact_foreground_kernel_and_engine_cancels(monkeypatch)
• record_run · function · L417-L420 — def record_run(self, task)
• fake_chat · function · L422-L427 — def fake_chat(messages, cfg, **kwargs)
• test_late_model_reply_after_stop_cannot_execute_or_submit · function · L453-L498 — def test_late_model_reply_after_stop_cannot_execute_or_submit(monkeypatch)
• record_run · function · L461-L464 — def record_run(self, task)
• late_chat · function · L466-L478 — def late_chat(messages, cfg, **kwargs)
• test_parent_stop_propagates_to_running_descendants · function · L501-L551 — def test_parent_stop_propagates_to_running_descendants(monkeypatch)
• cancellable_run · function · L508-L527 — def cancellable_run(self, task)
• test_live_steering_is_delivered_at_next_turn_boundary · function · L554-L606 — def test_live_steering_is_delivered_at_next_turn_boundary(monkeypatch)
• boundary_run · function · L560-L574 — def boundary_run(self, task)
• test_child_model_steps_and_policy_overrides_remain_visible · function · L609-L654 — def test_child_model_steps_and_policy_overrides_remain_visible(monkeypatch)
• fake_run · function · L612-L621 — def fake_run(self, task)
• test_stopping_one_child_leaves_its_siblings_running · function · L657-L689 — def test_stopping_one_child_leaves_its_siblings_running(monkeypatch)
• fake_chat · function · L669-L671 — def fake_chat(messages, cfg, **kwargs)
• test_stopping_a_parent_stops_its_descendants_but_not_a_cousin · function · L692-L723 — def test_stopping_a_parent_stops_its_descendants_but_not_a_cousin(monkeypatch)
• test_a_child_compacts_against_its_own_models_window · function · L731-L765 — def test_a_child_compacts_against_its_own_models_window()
• test_an_unknown_model_falls_back_rather_than_guessing · function · L768-L784 — def test_an_unknown_model_falls_back_rather_than_guessing()
• test_the_policy_actually_installs_the_provider · function · L787-L795 — def test_the_policy_actually_installs_the_provider()
• _step · function · L803-L821 — def _step(step_id, kind, phase, **extra)
• test_child_steps_are_forwarded_bounded_and_decorated · function · L824-L865 — def test_child_steps_are_forwarded_bounded_and_decorated(monkeypatch)
• fake_run · function · L831-L842 — def fake_run(self, task)
• test_child_step_flood_is_capped_with_one_elision_marker · function · L868-L895 — def test_child_step_flood_is_capped_with_one_elision_marker(monkeypatch)
• fake_run · function · L871-L876 — def fake_run(self, task)
• test_cli_runner_without_step_sink_leaves_child_dispatcher_unwired · function · L898-L912 — def test_cli_runner_without_step_sink_leaves_child_dispatcher_unwired(monkeypatch)
• fake_run · function · L901-L903 — def fake_run(self, task)
• test_collect_is_additive_with_request_attempt_and_artifact_refs · function · L915-L924 — def test_collect_is_additive_with_request_attempt_and_artifact_refs(monkeypatch)
• test_private_scratch_does_not_lift_trusted_capture_parallel_limit · function · L927-L939 — def test_private_scratch_does_not_lift_trusted_capture_parallel_limit()
• test_steering_policy_binds_only_the_providers_it_lacks · function · L947-L967 — def test_steering_policy_binds_only_the_providers_it_lacks()
• test_the_loop_hands_a_wrapped_policy_the_run_providers · function · L970-L1036 — def test_the_loop_hands_a_wrapped_policy_the_run_providers(monkeypatch)
• finalize_chat · function · L985-L1005 — def finalize_chat(messages, cfg, **kwargs)
• Wrapped · class · L1007-L1019 — class Wrapped
• init · method · L1008-L1010 — def init(self, cfg)
• bind_runtime · method · L1012-L1016 — def bind_runtime(self, **providers)
• prepare · method · L1018-L1019 — def prepare(self, state)
• _controlled_collect_children · function · L1039-L1059 — def _controlled_collect_children(runner, count, future_factory)
• test_collect_uses_one_deadline_for_all_unfinished_futures · function · L1063-L1089 — def test_collect_uses_one_deadline_for_all_unfinished_futures(monkeypatch, count)
• ClockedFuture · class · L1070-L1075 — class ClockedFuture(Future)
• result · method · L1071-L1075 — def result(self, timeout=None)
• test_collect_none_observes_parent_cancel_without_waiting_for_futures · function · L1092-L1130 — def test_collect_none_observes_parent_cancel_without_waiting_for_futures()
• ObservedFuture · class · L1100-L1103 — class ObservedFuture(Future)
• result · method · L1101-L1103 — def result(self, timeout=None)
• collect · function · L1109-L1113 — def collect()
• test_collect_rejects_invalid_timeout_before_waiting · function · L1137-L1143 — def test_collect_rejects_invalid_timeout_before_waiting(value)
• test_collect_zero_is_nonblocking_snapshot_with_all_result_identities · function · L1146-L1167 — def test_collect_zero_is_nonblocking_snapshot_with_all_result_identities()
• NoWaitFuture · class · L1149-L1151 — class NoWaitFuture(Future)
• result · method · L1150-L1151 — def result(self, timeout=None)
• test_collect_fast_result_is_not_lost_while_later_child_uses_remaining_budget · function · L1170-L1205 — def test_collect_fast_result_is_not_lost_while_later_child_uses_remaining_budget( monkeypatch, )
• CompletingFuture · class · L1179-L1189 — class CompletingFuture(Future)
• result · method · L1180-L1189 — def result(self, timeout=None)
• test_collect_does_not_hold_tree_lock_while_future_waits · function · L1208-L1239 — def test_collect_does_not_hold_tree_lock_while_future_waits()
• ObservedFuture · class · L1214-L1217 — class ObservedFuture(Future)
• result · method · L1215-L1217 — def result(self, timeout=None)
• collect · function · L1222-L1226 — def collect()
• test_collect_one_second_budget_wall_clock_smoke · function · L1242-L1257 — def test_collect_one_second_budget_wall_clock_smoke()
• test_agent_cancel_probe_reaches_collect_through_native_and_python · function · L1262-L1334 — def test_agent_cancel_probe_reaches_collect_through_native_and_python(entry)
• ObservedFuture · class · L1276-L1279 — class ObservedFuture(Future)
• result · method · L1277-L1279 — def result(self, timeout=None)
• collect · function · L1291-L1308 — def collect()
• test_collect_invalid_timeout_is_rejected_at_native_and_python_boundaries · function · L1338-L1362 — def test_collect_invalid_timeout_is_rejected_at_native_and_python_boundaries()
• test_parent_cancel_targets_owned_subtree_even_when_collect_selects_one · function · L1365-L1388 — def test_parent_cancel_targets_owned_subtree_even_when_collect_selects_one()
• test_single_child_stop_and_collect_leave_sibling_running · function · L1391-L1406 — def test_single_child_stop_and_collect_leave_sibling_running()
• test_collect_completed_future_failure_keeps_real_failed_state · function · L1412-L1425 — def test_collect_completed_future_failure_keeps_real_failed_state(failure)
• test_collect_cancelled_pending_future_reports_stopped_without_affecting_sibling · function · L1428-L1443 — def test_collect_cancelled_pending_future_reports_stopped_without_affecting_sibling()
• test_web_session_runner_binds_its_own_cancel_event_to_collect · function · L1447-L1484 — def test_web_session_runner_binds_its_own_cancel_event_to_collect()