MCPcopy Create free account

hub / github.com/Unakar/Logic-RL / functions

Functions858 in github.com/Unakar/Logic-RL

Method__init__
(self, cls, *args, **kwargs)
verl/single_controller/ray/base.py:130
Method__init__
(self, resource_pool: RayResourcePool = None, ray_cls_with_init: RayClassWit
verl/single_controller/ray/base.py:178
Method__init__
(self, resource_pool: RayResourcePool, ray_cls_with_init: RayClassWithInitArgs, **kwargs)
verl/single_controller/ray/megatron.py:31
Method__init__
(self, process_on_nodes=None, max_collocate_count: int = 10, n_gpus_per_node=8)
verl/single_controller/base/worker_group.py:28
Method__init__
(self, cls, *args, **kwargs)
verl/single_controller/base/worker_group.py:66
Method__init__
(self, resource_pool: ResourcePool, **kwargs)
verl/single_controller/base/worker_group.py:93
Method__init__
(self, store)
verl/single_controller/base/worker.py:75
Method__init__
(self, cuda_visible_devices=None)
verl/single_controller/base/worker.py:119
Method__init__
(self, resource_pool: ResourcePool, **kwargs)
verl/single_controller/base/megatron/worker_group.py:23
Method__init__
(self, cuda_visible_devices=None)
verl/single_controller/base/megatron/worker.py:22
Method__init__
(self, rank_zero_info)
verl/single_controller/base/register_center/ray.py:21
Method__init__
(self, tokenizer, num_examine)
verl/trainer/main_ppo.py:43
Method__init__
(self, config, device_mesh: DeviceMesh)
verl/trainer/fsdp_sft_trainer.py:60
Method__init__
(self, config, tokenizer, role_worker_mapping: dict[Role, W
verl/trainer/ppo/ray_trainer.py:328
Method__init__
(self, init_kl_coef, target_kl, horizon)
verl/trainer/ppo/core_algos.py:34
Method__init__
(self, kl_coef)
verl/trainer/ppo/core_algos.py:49
Method__init__
(self, config: DictConfig, role: str)
verl/workers/megatron_workers.py:69
Method__init__
(self, config)
verl/workers/megatron_workers.py:581
Method__init__
(self, config: DictConfig, role: str)
verl/workers/fsdp_workers.py:53
Method__init__
(self, config)
verl/workers/fsdp_workers.py:770
Method__init__
(self, module: FSDP, inference_engine: LLM, model_config,
verl/workers/sharding_manager/fsdp_vllm.py:36
Method__init__
(self, device_mesh: DeviceMesh)
verl/workers/sharding_manager/fsdp_ulysses.py:38
Method__init__
(self, model_provider)
verl/workers/sharding_manager/megatron_vllm.py:37
Method__init__
(self, module: AllGatherPPModel, inference_engine: LLM, model_config, layer_name_mapping)
verl/workers/sharding_manager/megatron_vllm.py:240
Method__init__
(self, config)
verl/workers/critic/base.py:28
Method__init__
(self, config, model_config, megatron_config, critic_module: nn.ModuleList, critic_optimizer:
verl/workers/critic/megatron_critic.py:43
Method__init__
(self, config, critic_module: nn.Module, critic_optimizer: optim.Optimizer)
verl/workers/critic/dp_critic.py:41
Method__init__
Args: dataloader: an Iterable of TensorDict that consistently generates prompts. Note that the dataloader should han
verl/workers/rollout/base.py:25
Method__init__
(self, module: nn.Module, config)
verl/workers/rollout/hf_rollout.py:37
Method__init__
A naive rollout. It requires the module to be compatible with huggingface APIs. That is: The module should define __call__ to receive input_id
verl/workers/rollout/naive/naive_rollout.py:38
Method__init__
A vLLM rollout. It requires the module is supported by the vllm. Args: module: module here follows huggingface APIs c
verl/workers/rollout/vllm_rollout/vllm_rollout.py:59
Method__init__
MeagtronPPOActor class. This class implements the simple PPO logics when the model is built with Megatron. Args: config (OmegaCon
verl/workers/actor/megatron_actor.py:50
Method__init__
The base class for PPO actor Args: config (DictConfig): a config passed to the PPOActor. We expect the type to be
verl/workers/actor/base.py:28
Method__init__
When optimizer is None, it is Reference Policy
verl/workers/actor/dp_actor.py:41
Method__init__
(self, config)
verl/workers/reward_model/base.py:25
Method__init__
(self, config, model_config, reward_model_module: torch.nn.
verl/workers/reward_model/megatron/reward_model.py:39
Method__init__
(self, config: LlamaConfig, megatron_config: ModelParallelConfig)
verl/models/llama/megatron/modeling_llama_megatron.py:157
Method__init__
(self, config: LlamaConfig, megatron_config: ModelParallelConfig)
verl/models/llama/megatron/modeling_llama_megatron.py:223
Method__init__
(self, config: LlamaConfig, megatron_config: ModelParallelConfig)
verl/models/llama/megatron/modeling_llama_megatron.py:281
Method__init__
(self, config: LlamaConfig, megatron_config: ModelParallelConfig, pre_process, post_process)
verl/models/llama/megatron/modeling_llama_megatron.py:410
Method__init__
(self, config: LlamaConfig, megatron_config: ModelParallelConfig, pre_process, post_process)
verl/models/llama/megatron/modeling_llama_megatron.py:516
Method__init__
(self, config: LlamaConfig, megatron_config: ModelParallelConfig)
verl/models/llama/megatron/layers/parallel_decoder.py:101
Method__init__
(self, config, megatron_config: ModelParallelConfig = None)
verl/models/llama/megatron/layers/parallel_mlp.py:33
Method__init__
(self, dim, max_position_embeddings=2048, base=10000, device=None, scaling_factor=1.0)
verl/models/llama/megatron/layers/parallel_attention.py:75
Method__init__
(self, dim, max_position_embeddings=2048, base=10000, device=None, scaling_factor=1.0)
verl/models/llama/megatron/layers/parallel_attention.py:94
Method__init__
(self, config: LlamaConfig, megatron_config: ModelParallelConfig)
verl/models/llama/megatron/layers/parallel_attention.py:146
Method__init__
(self, input_size, gate_ouput_size, up_output_size,
verl/models/llama/megatron/layers/parallel_linear.py:54
Method__init__
LlamaRMSNorm is equivalent to T5LayerNorm
verl/models/llama/megatron/layers/parallel_rmsnorm.py:27
Method__init__
(self, tokenizer, num_examine)
examples/split_placement/main_ppo_split.py:35
Method__len__
(self)
verl/protocol.py:180
Method__len__
(self)
verl/utils/dataset/rm_dataset.py:96
Method__len__
(self)
verl/utils/dataset/sft_dataset.py:107
Method__len__
(self)
verl/utils/dataset/rl_dataset.py:117
Method__lt__
(self, other)
verl/utils/seqlen_balancing.py:42
Method__lt__
(self, other)
verl/utils/seqlen_balancing.py:81
Method__new__
(cls, *args, **kwargs)
verl/single_controller/base/worker.py:85
Method__post_init__
(self)
verl/protocol.py:176
Method__repr__
(self)
verl/utils/seqlen_balancing.py:89
Method__setstate__
(self, data)
verl/protocol.py:204
Method__str__
(self)
tests/e2e/envs/digit_completion/task.py:56
Method_convert_id_to_token
(self, index: int)
tests/e2e/envs/digit_completion/tokenizer.py:98
Method_convert_token_to_id
(self, token: str)
tests/e2e/envs/digit_completion/tokenizer.py:95
Method_download_files
()
verl/utils/dataset/rm_dataset.py:72
Method_estimate_qwen2_flops
(self, tokens_sum, batch_seqlens, delta_time)
verl/utils/flops_counter.py:72
Method_estimate_unknown_flops
(self, tokens_sum, batch_seqlens, delta_time)
verl/utils/flops_counter.py:69
Method_forward_head
(self, hidden_states)
verl/models/llama/megatron/modeling_llama_megatron.py:377
Method_forward_head
(self, hidden_states)
verl/models/llama/megatron/modeling_llama_megatron.py:637
Method_get_pid
(self)
verl/single_controller/base/worker.py:66
Method_init_head
(self)
verl/models/llama/megatron/modeling_llama_megatron.py:368
Method_init_head
(self)
verl/models/llama/megatron/modeling_llama_megatron.py:628
Method_is_worker_alive
(self, worker: ray.actor.ActorHandle)
verl/single_controller/ray/base.py:205
Method_parse_cot_eval
(self, pred_str, ans, model_name=None)
eval_kk/kk_processor.py:191
Method_rebind_actor_methods
bind the method with actor_prefix to its original name
verl/single_controller/ray/base.py:298
Method_set_cos_sin_cache
(self, seq_len, device, dtype)
verl/models/llama/megatron/layers/parallel_attention.py:79
Method_set_cos_sin_cache
(self, seq_len, device, dtype)
verl/models/llama/megatron/layers/parallel_attention.py:98
Method_shape
(self, tensor: torch.Tensor, seq_len: int, bsz: int)
verl/models/llama/megatron/layers/parallel_attention.py:231
Method_tokenize
(self, text: str)
tests/e2e/envs/digit_completion/tokenizer.py:92
Methodadd_node
(self, process_count)
verl/single_controller/base/worker_group.py:35
Functionadd_one
(data)
tests/ray/test_worker_group_basics.py:83
Methodall_gather
(self)
tests/ray/test_worker_group_torch.py:60
Methodall_special_ids
`List[int]`: List the ids of the special tokens(`'<unk>'`, `'<cls>'`, etc.) mapped to class attributes.
verl/workers/rollout/tokenizer.py:53
Methodall_special_tokens
`List[str]`: A list of the unique special tokens (`'<unk>'`, `'<cls>'`, ..., etc.). Convert tokens of `tokenizers.AddedToken` type t
verl/workers/rollout/tokenizer.py:61
Functionapply_monkey_patch_to_llama
()
verl/models/transformers/monkey_patch.py:22
Functionapply_monkey_patch_to_qwen2
()
verl/models/transformers/monkey_patch.py:28
Functionapply_rotary_pos_emb_rmpad
(q, k, cos, sin, position_ids, indices, sequence_length)
verl/models/llama/megatron/layers/parallel_attention.py:299
Functionarithmetic_sequence_reward_function
(data: DataProto)
tests/e2e/arithmetic_sequence/rl/main_trainer.py:37
Methodbackward
(ctx: Any, *grad_output: Tensor)
verl/utils/ulysses.py:182
Methodbackward
(ctx, grad_output: torch.Tensor)
verl/utils/megatron/tensor_parallel.py:118
Methodbuild_inputs_with_special_tokens
(self, token_ids_0: List[int],
tests/e2e/envs/digit_completion/tokenizer.py:104
Methodbuild_memory_reference
(self)
verl/utils/memory_buffer.py:199
Functioncheck_workers_alive
(workers: List, is_alive: Callable, gap_time: float = 1)
verl/single_controller/base/worker_group.py:81
Methodchunk
(self, chunks: int)
verl/protocol.py:617
Functionclip_by_value
Tensor extenstion to torch.clamp https://github.com/pytorch/pytorch/issues/2793#issuecomment-428784713
verl/utils/torch_functional.py:86
Functioncollate_fn
(x: list['DataProtoItem'])
verl/protocol.py:143
Functioncollate_fn
(data_list: list[dict])
verl/utils/dataset/rl_dataset.py:31
Functioncollect_all_to_all
(worker_group, output)
verl/single_controller/base/decorator.py:70
Functioncollect_dp_compute_data_proto
(worker_group, output)
verl/single_controller/base/decorator.py:289
Functioncollect_megatron_compute_data_proto
Each output must be a DataProto. We concat the dim=0 of output
verl/single_controller/base/decorator.py:147
Functioncollect_megatron_pp_as_dp_data_proto
(worker_group, output)
verl/single_controller/base/decorator.py:246
Functioncollect_megatron_pp_only
Only collect output of megatron pp. This is useful when examine weight names as they are identical in tp/dp
verl/single_controller/base/decorator.py:223
← previousnext →501–600 of 858, ranked by callers