Get logging logger Args: log_file: Log filename, if specified, file handler will be added to logger. If None, defaults to 'm

Parse imports from code content (main entry point for backward compatibility) IMPORTANT: This function filters out external packages and onl

Perform a search using the Exa API with the provided search request parameters. :param search_request: An instance of ExaSearchReque

Update status with agent name, phase, and optional output

Parse a PDF file and generate various outputs including layout, markdown, content_list, etc. Args: f_path (str): The pat

Instantiate an LLM instance. Args: config(`DictConfig`): The omegaconf.DictConfig object. Returns: The LLM i

Generate response by the given messages. Args: messages(`List[Message]`): The previous messages. model(`Optional[str]

Start the server

Decode a list of token IDs back into a natural text string. Args: token_ids: List of token IDs to decode. Returns:

Build execution input for a skill, linking outputs from dependencies. Args: skill_id: The skill to build input for.

Load configuration from file

Helper method to run skill retrieval test. Args: queries: List of user queries to test. skill_name: Name of

Send message to all clients in a session

Dump the spec to the specified output directory. Args: output_dir (str): The directory to dump the spec files.

Push files to the remote hub.

Main method to execute the agent. This method should define the logic of how the agent processes input and generates output messages

Return a DownloadButton update payload compatible with newer Gradio versions.

Execute Python code string. Uses sandbox mode or local mode based on use_sandbox setting. Args: code: Python co

Log formatted output with a tag prefix. Args: content (Union[str, list]): Content to log. Can be a string or a list (for

Append to with automatic attribute injection.

Instantiate an LLM instance. Args: config_dir_or_id(`str`): The local task directory or id in the modelscope repository.

Save spec to markdown file.

Encode text into token IDs. Args: content: Input text string. Returns: List of token IDs.

Helper to run async coroutines in sync context.

Update session data

BaoStock session context manager with connection reuse

Create a minimal mock SkillSchema backed by a real directory. Args: skill_id: Unique skill identifier (e.g., 'skill_a@latest').

Get system status HTML

Check and install a package using pip. Note: The `package_name` may not be the same as the `import_name`. Args: package_name (s

Call query function for multiple data sources

Create standardized error response. Args: error: The exception that occurred operation: Name of the operatio

Execute a function with rate limiting if configured. Args: func: The function to execute ( can be sync or async)

Select data source based on stock code

Convert BaoStock query result to DataFrame

Save DataFrame to file in financial_data directory. Args: df: DataFrame to save filename: Filename (without

Helper to create a JSON stream from data

Generates a response based on the given conversation history and optional tools. Args: messages (`List[Message]`): The conversati

Get skill DAG for a query without executing. Args: query: User's query string. Returns: SkillDAGRes

Load index.json, creating empty structure if not exists.

Minimal config object compatible with ToolBase usage in this repo. Keep it SimpleNamespace-based so it's easy to tweak scenarios.

Save configuration to file

Add an execution record to the spec.

Link upstream skill output for downstream consumption.

Parses the given text content to extract JSON format data. It can parse JSON embedded within triple backticks (```json...```)

Run an async coroutine in a new event loop (sync context helper).

Convert the request parameters to a dictionary.

Convert code to AKShare symbol for a given market. - A-share: input like sh.600000/sz.000001 -> 600000/000001 for functions expecting plain d

Create success response with sample data. Args: df: Full DataFrame saved_path: Path where data was saved

Resolve JavaScript/TypeScript import path to file Returns path relative to output_dir with file extension. Returns None for external

Get a DOM element by tag and identifier. Finds an element by either its line number in the original file or by matching attr

Shutdown all executors.

Start the LSP server process

Non-blocking wrapper with controlled concurrency.

Inject RSID, author, and date attributes into DOM nodes where applicable. Adds attributes to elements that support them: - w:r: gets

Route tool calls to appropriate handler.

Remove log prefixes like [INFO:ms_agent] [agent_name]

Send final chat response with done=True

Generate random 8-character hex ID for para/durable IDs. Values are constrained to be less than 0x7FFFFFFF per OOXML spec: - paraId must be <

Check user authentication status

Get a specific project by ID

List tools available. Returns: A Dict of {server_name: tools}

Insert after with automatic attribute injection.