openai4s/agent/control.py

• call_reaches_dispatcher · function · L26-L55 — def call_reaches_dispatcher( name: Any, catalog: Any = None, arguments: Any = None ) -> bool
• _never_cancelled · function · L58-L59 — def _never_cancelled() -> bool
• execute_native_batch · function · L62-L183 — def execute_native_batch( batch: NativeToolBatch, invoke: ToolInvoker, *, limit: int = MAX_TOOL_CALLS_PER_TURN, cancelled: Callable[[], bool] = _never_cancelled, validate: ToolValidator = tool_validation_error, parallel_policy: ToolParallelPolicy | None = None, max_parallel_reads: int = _MAX_PARALLEL_READS, prepare_group: GroupPreparation | None = None, ) -> ExecutionOutcome
• tool_parallel_policy · function · L186-L203 — def tool_parallel_policy( call: NativeToolCall, catalog: Any = None, metadata_resolver: Callable[[str], Mapping[str, Any]] | None = None, ) -> tuple[bool, tuple[str, ...]] | None
• _execute_read_only_waves · function · L206-L261 — def _execute_read_only_waves( indices: list[int], calls: tuple[NativeToolCall, ...], scheduling: list[tuple[bool, tuple[str, ...]] | None], results: list[tuple[str, bool] | None], invoke: ToolInvoker, cancelled: Callable[[], bool], *, max_workers: int, prepare_group: GroupPreparation | None, ) -> None
• _safe_invoke · function · L264-L275 — def _safe_invoke( call: NativeToolCall, invoke: ToolInvoker, ) -> tuple[str, bool]
• _prepare_error · function · L278-L289 — def _prepare_error(prepare_group: GroupPreparation | None) -> str | None
• _cancelled_text · function · L292-L296 — def _cancelled_text(call: NativeToolCall) -> str
• _resources_conflict · function · L299-L322 — def _resources_conflict(left: tuple[str, ...], right: tuple[str, ...]) -> bool