启动同步管理器

Convert AITW action to Qwen2.5 action format

Enables gradient checkpointing for the model.

设置TCP保持连接选项

Check if the (y,x) point is contained in each bounding box. Args: yx: The (y, x) coordinate in pixels of the point. bounding_boxe

for single image multi-turn conversation conversation: [{'role': 'user', 'content': 'Describe this image'}, {'role': 'assi

embed_dim: output dimension for each position pos: a list of positions to be encoded: size (M,) out: (M, D)

embed_dim: output dimension for each position pos: a list of positions to be encoded: size (M,) out: (M, D)

Convert a string containing low-level thinking and action information to minicpm schema format Args: action_str (str): String co

Convert a string containing low-level thoughts and action information into minicpm schema format Args: action_str (str): String cont

Convert Qwen2.5 output to AITZ output

Convert Qwen2.5's output to minicpm's output

Will save the model, so you can reload it using `from_pretrained()`. Will only save from the main process.

Convert the ui-tars action string to the minicpm schema format Args: action_str (str): like "click(start_box='<|box_start|>(558,

Determines if two drag actions are the same.

Determines if two tap actions are the same.

Disables gradient checkpointing for the model.

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

Returns a sampler that ensures proper data sampling for GRPO training.

处理确认消息 (int)

处理节点队列长度更新 (dict)

处理同步优势请求 (SyncAdvantagesRequest)

处理任务状态 (TaskStatus)

初始化所有ZMQ套接字和网络连接

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