r"""Init a runner.

A股特色分析

分析筹码分布

分析筹码迁移

分析筹码稳定性

分析集中度变化趋势

分析机构调仓

分析新闻情绪

分析政策影响

分析社交媒体情绪

基础筹码分析

Bind the worker method to the WorkerGroup

Binds the methods of each worker to the WorkerDict. Note that we only bind public methods that are decorated by register

broadcast tensor in tp shards across mp_group

broadcast tensor in tp shards across mp_group

broadcast tensor in tp shards across mp_group

broadcast tensor in tp shards across mp_group

broadcast tensor in tp shards across mp_group

broadcast tensor in tp shards across mp_group

broadcast tensor in tp shards across mp_group

broadcast tensor in tp shards across mp_group

构建对话提示词

Build a formatted docstring from tool function metadata.

构建用于生成最终报告的提示词

Build the parameter buffer in each pp rank

Build a function signature from tool function metadata.

检查代码安全性，限制导入的库 Returns: (is_safe, error_message)

Check if the resource pool can be satisfied in this ray cluster.

Clean Numbers in the given string >>> _clean_numbers(None, "Hello 123") 'Hello 123' >>> _clean_numbers(None, "Hello 1234") 'Hell

筹码集中度分析

This function should only be called inside by WorkerGroup

构建API请求的负载数据 Args: question_text (str): 问题文本内容 Returns: Dict: 格式化的请求数据字典

Create a JSON schema for the given type.

Create schema for Union types.

确定趋势方向

评估集中度水平

hdfs capable to check whether a file_path is exists

Expands attention_mask from `[bsz, seq_len]` to `[bsz, 1, tgt_seq_len, src_seq_len]`.

Expands attention_mask from `[bsz, seq_len]` to `[bsz, 1, tgt_seq_len, src_seq_len]`.

Expands attention_mask from `[bsz, seq_len]` to `[bsz, 1, tgt_seq_len, src_seq_len]`.

Extract HTML code from LLM response

Fetch and add web content to search results.

Fetch and add web content to search results.

Fetch content for a single search result.

Fetch content for a single search result.

r"""Clean the cached memory and resets the runner.

根据 material_id 从 .jsonl 文件中查找【所有】对应的规则。 现在返回一个包含所有匹配规则的列表，而不是单个字典。

Format data to a JSON-serializable dictionary. Args: data: The data to format, typically from efinance Returns:

r"""Post-process the response text. Based on: https://huggingface.co/spaces/Lyte/DeepSeek-R1-Distill-Qwen-1.5B-Demo-GGUF/blob/main/app.py