Make causal mask used for bi-directional self-attention.

Make causal mask used for bi-directional self-attention.

Log a table of validation samples to the configured logger (wandb or swanlab)

Calculate the mapping of global layer_idx to local layer_idx Returns: layer_map (Dict: int -> tuple(int, int, int)): mapping f

Calculate the mapping of global layer_idx to local layer_idx Returns: layer_map (Dict: int -> tuple(int, int, int)): mapping f

Calculate the mapping of global layer_idx to local layer_idx Returns: layer_map (Dict: int -> tuple(int, int, int)): mapping f

Calculate the mapping of global layer_idx to local layer_idx Returns: layer_map (Dict: int -> tuple(int, int, int)): mapping f

hdfs mkdir

配置优化器

解析分析内容，分离问题分析、选项分析和解题过程

解析答案文件，将分组格式转换为按索引访问的答案列表

Parse Bing search result HTML to extract search results and the next page URL. Returns: tuple: (List of SearchItem objec

Parse Bing search result HTML to extract search results and the next page URL. Returns: tuple: (List of SearchItem objec

解析输入CSV行数据，提取问题ID和问题内容 Args: csv_row (List[str]): CSV行数据列表 Returns: Tupl

Attempts to parse latex to an expression sympy can read.

Attempts to parse latex to an expression sympy can read.

Execute search with the given engine and parameters.

Execute search with the given engine and parameters.

For each param, if it is a tp-splited param, we all-gather from micro_dp group.

准备HTTP请求头 Returns: Dict[str, str]: 包含认证信息的请求头字典

Prepare battle results.

处理基金申购赎回数据

处理新闻数据

统一处理LLM响应，判断行动类型并执行相应操作 Args: response: LLM的响应内容 Returns: 处理结果字典

特殊基金股吧评论数据的日期的处理（补全缺失年份） 参数: review_data (DataFrame): 原始股吧评论数据 str_fund_code (str): 基金代码字符串 返回:

处理上证指数数据

r"""Helper function to read JSON/JSONL files using fsspec.

Run final voting phase.

Run a single agent's debate turn with limited steps.

Run a single agent's voting turn.

Run structured debate rounds with cumulative context passing.

Save generated HTML to a file

保存结果到Excel和JSON文件

使用报告管理器保存HTML

DuckDuckGo 搜索

搜狗搜索

Synchronous Bing search implementation to retrieve search results. Args: query (str): The search query to submit to Bing

Synchronous Bing search implementation to retrieve search results. Args: query (str): The search query to submit to Bing

Send specific debate instruction to current speaker.

Send comprehensive research results to all agents.

Send voting instruction to agent.

Determine if tool execution should finish the agent

Show research metrics summary

Parses an expression with sympy.

Parses an expression with sympy.

套牢区分析

筹码变化趋势分析

Try all search engines in the configured order.

Try all search engines in the configured order.

Validate config options not implemented for Megatron backend

Validate config options not implemented for Megatron backend

异步工作函数，执行单个任务并处理异常

r"""Abort the processes recursively in a bottom-up way.

将文档列表保存到向量库中 参数： docs: 文档列表

Add highlight if content is significant

r"""Add empty thought to assistant message.

Add a single tool to the collection. If a tool with the same name already exists, it will be skipped and a warning will be logged.

r"""Set module as a leaf module to skip partitioning in deepspeed zero3.

r"""Align the dataset to a specific format. Aligned dataset: _prompt: [{"role": "user", "content": "..."}] * (2T - 1) _response: [{"role"