Parse resource data into Resource objects.

Populate selected tools in debug info.

Process a single line and decide whether to output it.

Apply rate limiting by adding delay between API calls

Resolve the nanobot config path from env overrides or defaults.

Execute HTTP request and retry Args: name: RPC method name payload: Request payload scri

Execute one task on the given OpenSpace instance and persist the result. In concurrent mode, uses tracker.begin_task/end_task with ContextVar.

Sanitize MCP tool schema to ensure Claude API compatibility (JSON Schema draft 2020-12). Fixes: - Empty schemas -> valid object sche

Save embeddings to disk cache.

Return platform-specific kwargs that allow timeout cleanup.

Tokenize text for BM25.

Truncate message content to avoid huge log files.

Compute combined unified diff between two file snapshots.

Update UI with current state

Upsert one tool_quality_records row + its execution history. Caller MUST hold ``self._mu``. Does NOT commit — caller manages the tra

Write ``.upload_meta.json`` so ``upload_skill`` can read pre-saved metadata. Called after evolution (execute_task auto-evolve or fix_skill).

Quote a YAML scalar value if it contains special characters.

Strip surrounding quotes and unescape a YAML scalar value.

Register a newly-created skill (DERIVED / CAPTURED). Does NOT overwrite an existing entry with the same ``skill_id``.

Analyze trajectory and return statistics.

Build search candidate dicts from cloud metadata/search items. Args: cloud_items: Items from cloud metadata or embedding search endpoints

Build a prompt fragment with the full content of *skills*. Injected as a system message into the agent's messages before the user ins

Build pyautogui command from action type and parameters. Args: action_type: Type of action (e.g., 'CLICK', 'TYPING') par

* Calculate expense breakdown by category

Truncate oversized individual message contents in-place. Targets tool-result messages and assistant messages that can carry enormous file con

Clear the cache.

Remove skill guidance (used before fallback execution).

Close the HTTP session.

Create the underlying session/connection. For JSON-RPC mode, we don't use a connection manager.

Get display name for an agent.

GET /records/{record_id}/download — download artifact zip bytes.

Execute one evolution action. Returns new SkillRecord or None. The global semaphore is NOT acquired here — it is managed at the trigg

Atomic evolution: insert new version + deactivate old version. **FIXED** — Same-name skill fix: - ``new_record.name`` is the same a

Execute a pyautogui Python command locally via subprocess.

Finalize recording, save final information

Format conversation history to readable text (for logging/debugging)