Validate task data format

Add assistant message, optionally with tool calls.

Apply proper indentation to a line based on its relative indent in patch.

Add fields from `src` to `dst`, skipping undefined values.

Best-effort mirror write on host filesystem.

* Filter out elements that should not be exported (MiniMap, Controls, etc.)

Execute a sub-module workflow. Calls another YAML workflow file as a reusable sub-module with parameter passing. The sub-module runs

Execute if/then/else conditional branching. Evaluates a condition and executes either the 'then' or 'else' branch. Args:

Execute a for_each loop over items. Iterates over a list, executing nested steps for each item. The current item is made available in

Increment an integer variable in context. Args: step_data: Contains 'increment' key with the variable name. context:

Execute a single LLM step with tool calling loop. Prepares messages and tools, then delegates to multi_step_tool_call_loop for the ac

Execute switch/case style multi-way branching. Selects and executes one branch based on a variable's value. Falls back to default bra

Extract the answer from [ANSWER]...[/ANSWER] tags in the response.

Return the current MCP Streamable HTTP session id, if known. This is the value that must be persisted in checkpoints to allow resumi

Human-readable summary for the orchestrator LLM.

Return a summary of token usage.

Print and log messages. Thread-safe for parallel execution.

Resolve a system prompt with template expansion.

Restore workspace from backup during resume using rsync. Falls back to shutil.copytree if rsync is not available.

Start the interactive agentic loop against a running sandbox VM.

Serialize data to JSON with support for complex types. Handles serialization of: - Dataclasses (converted to dict) - Sets and tuples (con

Return the sandbox-side output directory for a specific query. Mirrors the host-side layout so paths are easy to find:: outputs/{experim

Merge orchestrator and MCP tools into OpenAI function-calling format.

Stop the server and exit when there are no more clients.

Validate YAML syntax

Copy a file to *backup_dir* preserving its relative path. Returns the absolute path inside backup_dir on success, None on failure.

Single LLM call with system prompt, no tools.

Capture a screenshot and optionally annotate it with Set-of-Marks. Returns a dict with zero or more of: screenshot_filename: vpath to the r

Configure tracing state for the LLMExecutor. Args: trace_writer: TraceWriter for recording events replay_events: List

Copy all submodule YAMLs referenced (recursively) by the workflow. Submodules are copied under a `submodules/` directory inside the reproduci

Download a file from a URL. Returns True on success.

Lazy-load the BM25 index and corpus lookup on first use.

Execute a shell command via docker exec.

Expand template variables

r"""Extract all \boxed{...} contents, handling nested braces.

Extract YAML from a ```yaml fenced code block, or use raw text.

Get the minimum indentation from a list of lines (the baseline). Args: lines: List of code lines Returns: The minimum i

Infer Lean BaseType from a JSON parameter value.

Infer set_variable output type; keep passthrough type when possible.

Run the inner loop with a custom tool set. Temporarily swaps tool lists, runs _inner_loop, then restores. Used by plan mode phases to

Invoke a submodule as a tool call. Looks up the submodule specification, resolves parameters from context and tool arguments, then ex

Check if a submodule result contains the submit completion signal. When ``require_submodule_submit`` is enabled, the submit_changes s

Heuristic check: read first *sample_size* bytes and look for null bytes.

Compact preview for big dict payloads.

Load KEY=VALUE pairs from an env file into os.environ.

Parse step (with conversation history)

Parse loop step

Parse conditional step

Parse increment step

Parse switch statement

Parse while loop