Compute average trust across all nodes.

Merge two version counters (take component-wise max). Acquires locks on both clocks to get consistent snapshots.

Get multiple values.

Walk *project_root* and produce a :class:`MigrationReport`. The function never raises for individual file errors — those are aggregated under

Human-readable diff for a failed fixture.

Simple mock MCP server that responds to tool calls. Reads JSON-RPC from stdin, writes responses to stdout.

Set multiple key-value pairs.

Process a task safely through the kernel.

My function.

Check if message requires human escalation.

* Generate a normalized key for a rule based on its semantics * (action + non-surface conditions), so we can group rules that * do the same thin

Return normalized extension filters from a comma-separated string.

Send event to all matching webhooks in a background thread.

Convenience method to notify about a policy violation.

Return RFC3339-like UTC timestamp.

Demonstrate the Observer processing the signals and learning.

Record failed chain interaction and update trust.

Called when a chain errors out.

Log chain start with agent DID.

Event-level audit enrichment.

Called when LLM finishes generating.

Handle LLM start event. Args: serialized: Serialized LLM configuration prompts: List of prompts run_id: U

Called when LLM starts generating.

Called when agent is paused (SIGSTOP). Override to implement shadow mode or inspection behavior.

Called when a query errors out.

Called when a retriever errors out.

Record tool errors for audit trail.

Wrap the new OpenAI Agents SDK with governance.

Wrap OpenAI Assistants API with governance.

Original function.

* Parse natural language description into structured data.

* Parse description into policy rules.