Get from cache - RACE CONDITION on hit/miss counts.

Mock execute - just returns the query for inspection.

Set in cache - RACE CONDITION on dict modification.

Helper to retrieve a ticket by ID

Validate and resolve memory paths to prevent directory traversal attacks. Args: path: The path to validate (must start w

Safely divide two numbers, returning default if denominator is zero.

Format data as JSON string, truncating if too long.

Generate dashboard view of validation results.

Get the project root directory.

Delete the agent pod for a session. Searches by label first (works for both claimed standby and on-demand pods), then falls back to the conve

Execute a memory tool command. Args: **params: Command parameters from Claude's tool use Returns: D

Find all notebooks in a directory. Args: root_dir: Root directory to search exclude_patterns: List of glob patterns to exclu

Generate Basic auth header for Confluence API.

Parse a Claude API response into a structured format.

Project future cash flows based on assumptions. Returns: Dictionary with projected financials

Review code with memory-enhanced analysis. Args: code: The code to review filename: Name of the file being r

Save current state to file.

Validate a single notebook.

Run all structural validations on a notebook. This validates the notebook without executing it.

Visualize a Claude API message in the terminal.

Build a V1Pod manifest for an agent pod. A V1Pod is the Python representation of a Kubernetes Pod spec. It has two main sections: - me

Return the first text block's content (skips thinking/tool blocks).

Return names of standby pods that are Ready to serve a session. Uses a K8s label selector to filter — this is efficient because the API serve

Check if content is a list of SDK message objects. Uses duck-typing to check for message-like objects rather than relying on fragile cla

Return the session's pod IP if it exists and belongs to ``tenant``. ``None`` means the session doesn't exist yet — the caller may create it a

True when the pod is Running, has an IP, and all containers are Ready. "Running" only means the container process started; the readiness probe

Render content as a code block. Args: content: String to display in code block Returns: HTML pre/code block string

Render text as markdown HTML if the markdown library is available. Enables extensions for tables, fenced code blocks, and other common markd

Extract and render the final assistant text from a message list. Searches backwards through messages to find the last AssistantMessage w

Top up the standby pool to STANDBY_POOL_SIZE. Called after a pod is claimed or deleted. Creates pods one at a time and re-counts the pool be

Kick off pool replenishment as a background asyncio task. This is fire-and-forget — the caller doesn't wait for replenishment to finish. If

Poll a pod until it is Running *and* Ready. Returns the pod IP. K8s pod phases: Pending -> Running -> Succeeded/Failed. We need to wait beca

Auto-fix safe issues like deprecated models.

Calculate enterprise value by discounting cash flows. Args: terminal_method: Method for terminal value calculation

Fallback display for non-Jupyter environments.

Display the final assistant response from a conversation in a styled card. Extracts the last text response from an agent's message history a

Export results as GitHub issue markdown.

Extract the model identifier from a list of messages. Looks for model information in SystemMessage or ResultMessage. Args: mess

Return the contents of the last <result>...</result> in `text`, or None.

Generate a batch of tickets

Get logs from a Docker container.

Interpret a single ratio with context. Args: ratio_name: Name of the ratio value: Calculated ratio value

Load a notebook from disk.

Load the notebook registry.

Parse cells from a notebook structure.

Reset the subagent tracking context. Call before starting a new query to ensure clean state for subagent tracking. Example:: #

Run validation on all notebooks.

Score a candidate based on weighted criteria

Send a JSON-RPC error response.

Send a JSON-RPC response to stdout.

Validate that all code cells have been executed. Returns a list of issues found.

Validate that code cells were executed in order. Returns a list of issues found.

Validate that no cells have error outputs. Returns a list of issues found.

Validate that no cells contain hardcoded API keys or secrets. Returns a list of issues found.

Generate appendix Tables B1-B5 and C1-C4. Deterministic (seeded hash, no imports), so repeat kernel runs are identical and COMPACTION_PROBES

Assess overall financial health based on ratio analysis.

Build the same agent config as notebook 00, plus hosting concerns.

Try to atomically claim a standby pod for a session. Returns pod IP or None. Atomically claim by patching labels. If two gateways race to claim

Shared client for both webhook verification and the work poller. Async because ``client.beta.environments.work.poller(...)`` is async-only (i

Shared client for both webhook verification and the work poller. Lazy because ``modal deploy`` imports this module locally, where the secret

Count standby pods that exist or are on their way (Pending or Running). Used when deciding whether to create more. Unlike ``_get_standby_pods``

Create or overwrite a file.

Create a single standby pod and return its name. Standby pods are pre-warmed: they pull the image, start the container, and sit idle waiting