Called when LLM errors out.

React to grid operator price signal

Intercept agent responses for output governance. Scans responses for blocked patterns and runs ``post_execute`` drift detection.

Register a callback for when an agent's trust is revoked.

Register a signal handler.

Register a callback for state changes

Audit-only hook for graph edge traversals. Does not block by default. Records every node->node transition for the governance audit tr

Called when synthesis ends.

Called when synthesis starts.

Handle tool end event. Args: output: Tool output run_id: Unique run identifier parent_run_id: Parent run

Handle tool error event. Args: error: The error that occurred run_id: Unique run identifier parent_run_id

Handle tool start event with trust verification. Args: serialized: Serialized tool configuration input_str: Tool inpu

Analyze incoming transaction

Get all open or half-open circuit breakers.

Return the original unwrapped agent before governance wrapping.

Return the mean score across all assessed dimensions.

95th percentile query latency in milliseconds.

95th percentile chain latency in milliseconds.

Trigger a kernel panic. This is a catastrophic, unrecoverable failure that halts all agent processing. The panic is recorded in the f

Add parallel execution. Args: steps: Steps to run in parallel. collect_all: Whether to wait for all or return first.

Parse sections and assign content tiers. Args: sections: List of document sections doc_type: Type of

Parse JSON string. Args: data: JSON string to parse Returns: Dict with parsed data

Parse a PDF or text document and extract text content. Args: file_path: Path to the PDF or text file Returns:

Parse YAML string safely. Uses yaml.safe_load to prevent arbitrary code execution. Args: data:

Active participants in this session.

True if all scenarios passed.

Pause the rollout — not available in Public Preview.

Send SIGSTOP to pause an agent.

Get all pending escalation requests.

Calculate percentage.

Engine that denies nothing.

True for decisions whose execution side proceeds with the action. Mirrors `core/src/verdict.rs::Decision::permits`: ``allow``, ``warn``,

Get the message store.

Get the current shutdown phase

Create a simple two-agent pipeline with policy check. Example: pipeline = pipe_agents( research_agent, "research",

Return the configured mock platform identifier.

Manage AgentMesh plugins.

Manage AgentMesh plugins.

Access loaded plugins

Transform context for Product Manager.

Get the agent's active policies.