Generate cache key from relative path.

Query the Gremlin graph Args: query (str): a query to be executed Returns: List[Dict[str, Any]]: a

Query the graph by taking a cypher query, converting it to an age compatible query, executing it and converting the result A

Create a chat completion (similar to OpenAI's chat.completions.create). Args: model: Model identifier (e.g., "go

End a memory session. Args: memory_name: Name of the memory system ctx: Memory context

Put data in cache with size tracking.

Get all browser pages/tabs using CDP Target.getTargets.

Since AGE suports only alphanumerical labels, we will encode generic label as HEX string Args: label (str): the original

Ensure we have a session ID for this target.

Strip double quotes and format as a proper field name

Close client and output container.

Encode content - not supported for PDF files.

Set variable values in a tool and create a new version. Args: tool_name: Name of the tool to update variable_

Type text with optional delay between keystrokes.

Check if the storage should be reloaded

Check if the file path is a URL.

Ensure that there is always an event loop available. This function tries to get the current event loop. If the current event loop is closed

Create a tool instance and store it. Args: tool_config: Tool configuration Returns: Tool

Copy a file from source to destination. Args: src_path (str): The ABSOLUTE path of the source file. It should be based on

Execute JavaScript in the target. Args: page_function: JavaScript code that MUST start with (...args) => format *args: Arguments to pass to t

Get agent configuration by name Args: agent_name: Agent name Returns: AgentConfig: Agent

Get the complete value of the variable - through rendering template and sub-variables

Insert data into a table. Supports both single row (dict) and multiple rows (list) insertion. Args: requ

Register a symbol that can be auto-injected into dynamic code. Args: name: Symbol name (e.g., "TOOL", "Tool")

Search for similar documents. Args: request: Search request with query and parameters Returns:

Start listening video stream Args: threaded: Run stream loop in a different thread to avoid blocking daemon_

Update an existing environment with new configuration and create a new version Args: env_cls: New environment class with

Get or create client for an account (lazy initialization). Args: account_name: Account name Returns: