Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/Unakar/Logic-RL
/ functions
Functions
858 in github.com/Unakar/Logic-RL
⨍
Functions
858
◇
Types & classes
113
↳
Endpoints
30
↓ 1 callers
Function
make_prefix
(dp, template_type)
examples/data_preprocess/countdown.py:53
↓ 1 callers
Function
make_prefix
(dp, template_type)
examples/data_preprocess/kk.py:10
↓ 1 callers
Function
make_prefix
(dp)
examples/data_preprocess/multiply.py:69
↓ 1 callers
Function
make_prefix
(dp)
examples/data_preprocess/arth.py:79
↓ 1 callers
Function
make_reward_function
(tokenizer, num_examine)
tests/e2e/arithmetic_sequence/rl/main_trainer.py:35
↓ 1 callers
Function
masked_var
Compute variance of tensor with masked values.
verl/utils/torch_functional.py:112
↓ 1 callers
Function
merge_resource_pool
(rp1: RayResourcePool, rp2: RayResourcePool)
verl/single_controller/ray/base.py:114
↓ 1 callers
Function
normalize_model_name
Transform the model name in each model_chunk in each pp stage into the name in inference engine
verl/utils/model.py:192
↓ 1 callers
Function
offload_fsdp_grad
(module)
verl/utils/fsdp_utils.py:79
↓ 1 callers
Function
offload_megatron_param_and_grad
(module_list: nn.ModuleList, offload_grad=False, hybrid_engine=None)
verl/utils/megatron_utils.py:226
↓ 1 callers
Method
offload_params_to_cpu
offload params of models that are not of current pp rank to cpu
verl/workers/sharding_manager/megatron_vllm.py:157
↓ 1 callers
Function
pad_to_sequence_parallel
pad the tokens such that the total length is a multiple of sp world size Args: unpad_tokens: (total_nnz, ...). Tokens after removing padd
verl/utils/megatron/sequence_parallel.py:29
↓ 1 callers
Function
parallel_put
(data_list, max_workers=None)
verl/utils/ray_utils.py:23
↓ 1 callers
Function
parse_cot_eval
(pred_str, ans, conclusion_patterns=['CONCLUSION:'], verbose=False,
eval_kk/kk_processor.py:14
↓ 1 callers
Function
parse_cot_eval_instruct
(pred_str, ans, conclusion_patterns=['<answer>'], verbose=False,
eval_kk/kk_processor.py:88
↓ 1 callers
Function
parse_model_answer
Parses model's answer text into status dictionary. Args: answer_text: Text extracted from model's <answer> tags expected_name
eval_kk/compute_score.py:61
↓ 1 callers
Function
parse_model_answer
Parses model's answer text into status dictionary. Args: answer_text: Text extracted from model's <answer> tags expected_name
verl/utils/reward_score/kk.py:60
↓ 1 callers
Function
parse_solution_text_format
Parses ground truth solution text into status dictionary. Args: solution_text: Formatted solution text from dataset Retu
eval_kk/compute_score.py:34
↓ 1 callers
Function
parse_solution_text_format
Parses ground truth solution text into status dictionary. Args: solution_text: Formatted solution text from dataset Retu
verl/utils/reward_score/kk.py:33
↓ 1 callers
Method
re_encode_by_rm_tokenizer
(self, data: DataProto)
verl/workers/reward_model/megatron/reward_model.py:58
↓ 1 callers
Function
remove_right_units
(string)
verl/utils/reward_score/math.py:140
↓ 1 callers
Function
save_final_acc_results
Save final accuracy results to a file.
eval_kk/main_eval_instruct.py:108
↓ 1 callers
Method
save_to_disk
(self, filepath)
verl/protocol.py:215
↓ 1 callers
Function
select_reward_fn
(data_source)
verl/trainer/main_eval.py:27
↓ 1 callers
Function
set_basic_config
This function sets the global logging format and level. It will be called when import verl
verl/utils/logging_utils.py:18
↓ 1 callers
Function
set_pad_token_id
Set pad_token_id to eos_token_id if it is None. Args: tokenizer (transformers.PreTrainedTokenizer): The tokenizer to be set.
verl/utils/tokenizer.py:20
↓ 1 callers
Function
slice_input_tensor
(x: Tensor, dim: int, padding: bool = True, group: ProcessGroup = None)
verl/utils/ulysses.py:116
↓ 1 callers
Method
start_worker_aliveness_check
(self, every_n_seconds=1)
verl/single_controller/base/worker_group.py:121
↓ 1 callers
Function
test
()
tests/ray/test_check_worker_alive.py:20
↓ 1 callers
Function
test_basics
()
tests/ray/test_ray_local_envs.py:36
↓ 1 callers
Function
test_basics
()
tests/ray/test_worker_group_basics.py:90
↓ 1 callers
Function
test_hf_casual_fwd
()
tests/model/test_transformers_ulysses.py:50
↓ 1 callers
Function
test_hf_casual_fwd_bwd
()
tests/model/test_transformers_ulysses.py:128
↓ 1 callers
Function
test_hf_casual_models
()
tests/model/test_transformer.py:32
↓ 1 callers
Function
test_hf_value_models
()
tests/model/test_transformer.py:91
↓ 1 callers
Function
test_memory_buffers
()
tests/gpu_utility/test_memory_buffers.py:27
↓ 1 callers
Method
train_model
(self, data: DataProto)
tests/ray/detached_worker/server.py:120
↓ 1 callers
Method
training_step
(self, batch: TensorDict)
verl/trainer/fsdp_sft_trainer.py:252
↓ 1 callers
Function
unfold_batch_dim
Unfold the first n dims as new batch dim
verl/protocol.py:124
↓ 1 callers
Function
union_two_dict
Union two dict. Will throw an error if there is an item not the same object with the same key. Args: dict1: dict2: Returns:
verl/utils/py_functional.py:22
↓ 1 callers
Function
unit_convert
(number, level)
verl/utils/flops_counter.py:23
↓ 1 callers
Method
update_sampling_params
(self, **kwargs)
verl/workers/rollout/vllm_rollout/vllm_rollout.py:126
↓ 1 callers
Function
validate_equation
Validate that equation only uses available numbers and each number once.
verl/utils/reward_score/countdown.py:28
↓ 1 callers
Function
validate_response_structure
Performs comprehensive validation of response structure. Args: processed_str: Processed response string from the model R
eval_kk/compute_score.py:92
↓ 1 callers
Function
validate_response_structure
Performs comprehensive validation of response structure. Args: processed_str: Processed response string from the model R
verl/utils/reward_score/kk.py:99
↓ 1 callers
Method
validation_step
(self, batch: TensorDict)
verl/trainer/fsdp_sft_trainer.py:288
↓ 1 callers
Function
vocab_parallel_compute_entropy_loss
Compute Categorical entropy loss Args: logits: `(torch.Tensor)` shape: (bs, response_length, vocab_size) eos_mask: `(
verl/utils/megatron/tensor_parallel.py:168
↓ 1 callers
Function
vocab_parallel_entropy
Compute entropy when the logits are sharded in tp ranks Args: vocab_parallel_logits: (total_nnz, vocab_size // tp_size) Returns:
verl/utils/megatron/tensor_parallel.py:124
↓ 1 callers
Function
write_jsonl
Write data to a JSONL file.
eval_kk/main_eval_instruct.py:21
Method
__call__
(self, *args: Any, **kwds: Any)
verl/utils/megatron_utils.py:222
Method
__call__
(self, placement_group, placement_group_bundle_idx, use_gpu
verl/single_controller/ray/base.py:142
Method
__call__
(self)
verl/single_controller/base/worker_group.py:42
Method
__call__
(self)
verl/single_controller/base/worker_group.py:77
Method
__call__
We will expand this function gradually based on the available datasets
verl/trainer/main_ppo.py:47
Method
__call__
(self, *inputs, **kwargs)
verl/workers/sharding_manager/megatron_vllm.py:146
Method
__call__
We will expand this function gradually based on the available datasets
examples/split_placement/main_ppo_split.py:39
Method
__enter__
(self)
verl/workers/sharding_manager/fsdp_vllm.py:69
Method
__enter__
(self)
verl/workers/sharding_manager/base.py:23
Method
__enter__
(self)
verl/workers/sharding_manager/fsdp_ulysses.py:43
Method
__enter__
(self)
verl/workers/sharding_manager/megatron_vllm.py:345
Method
__exit__
(self, exc_type, exc_value, traceback)
verl/workers/sharding_manager/fsdp_vllm.py:93
Method
__exit__
(self, exc_type, exc_value, traceback)
verl/workers/sharding_manager/base.py:26
Method
__exit__
(self, exc_type, exc_value, traceback)
verl/workers/sharding_manager/fsdp_ulysses.py:51
Method
__exit__
(self, exc_type, exc_value, traceback)
verl/workers/sharding_manager/megatron_vllm.py:360
Method
__getitem__
(self, item)
verl/protocol.py:189
Method
__getitem__
(self, item)
verl/utils/dataset/rm_dataset.py:114
Method
__getitem__
(self, item)
verl/utils/dataset/sft_dataset.py:110
Method
__getitem__
Note that we also return the raw_input_ids so that it can be combined with other chat template
verl/utils/dataset/rl_dataset.py:120
Method
__getstate__
(self)
verl/protocol.py:194
Method
__init__
(self, cot=True, no_linebreak=True)
eval_kk/kk_processor.py:150
Method
__init__
(self)
tests/ray/test_data_transfer.py:39
Method
__init__
(self, rank, world_size, group_name)
tests/ray/test_rvdz.py:21
Method
__init__
(self, cuda_visible_devices=None)
tests/ray/test_high_level_scheduling_api.py:26
Method
__init__
(self, size)
tests/ray/test_worker_group_torch.py:52
Method
__init__
(self, config)
tests/ray/test_colocated_workers.py:39
Method
__init__
(self)
tests/ray/test_driverfunc_to_worker.py:32
Method
__init__
(self)
tests/ray/test_driverfunc_to_worker.py:38
Method
__init__
(self)
tests/ray/test_ray_local_envs.py:28
Method
__init__
(self, x)
tests/ray/test_worker_group_basics.py:44
Method
__init__
(self)
tests/ray/check_worker_alive/main.py:29
Method
__init__
(self)
tests/ray/detached_worker/server.py:51
Method
__init__
Args: max_number: the maximum number allowed in the arithmetic sequence max_diff: the maximum diff. The actual commo
tests/e2e/envs/digit_completion/task.py:35
Method
__init__
Character tokenizer for Hugging Face transformers. Args: characters (Sequence[str]): List of desired characters. Any character wh
tests/e2e/envs/digit_completion/tokenizer.py:31
Method
__init__
(self)
verl/utils/megatron_utils.py:218
Method
__init__
(self, config: PretrainedConfig)
verl/utils/flops_counter.py:61
Method
__init__
(self, project_name, experiment_name, default_backend: Union[str, List[str]] = 'console', config=None)
verl/utils/tracking.py:27
Method
__init__
(self)
verl/utils/seqlen_balancing.py:29
Method
__init__
(self, items: List[Tuple[int, int]], k: int)
verl/utils/seqlen_balancing.py:51
Method
__init__
(self, dictionary, **kwargs)
verl/utils/py_functional.py:50
Method
__init__
(self, module: nn.Module)
verl/utils/memory_buffer.py:146
Method
__init__
(self, transform_memory_param_fn)
verl/utils/memory_buffer.py:175
Method
__init__
(self, fn)
verl/utils/model.py:30
Method
__init__
(self, numel, numel_padded, dtype)
verl/utils/megatron/memory.py:20
Method
__init__
(self, remote_logger=None, enable_wandb=False, print_to_console=False)
verl/utils/logger/aggregate_logger.py:32
Method
__init__
(self, parquet_files: Union[str, List[str]], tokenizer, pro
verl/utils/dataset/rm_dataset.py:42
Method
__init__
(self, parquet_files: Union[str, List[str]], tokenizer, pro
verl/utils/dataset/sft_dataset.py:39
Method
__init__
(self, parquet_files: Union[str, List[str]], tokenizer: PreTrainedTokenizer,
verl/utils/dataset/rl_dataset.py:63
Method
__init__
(self, hdfs_dir, verbose)
verl/utils/debug/trajectory_tracker.py:52
Method
__init__
(self, nccl_id)
verl/utils/rendezvous/ray_backend.py:27
Method
__init__
(self, process_on_nodes: List[int] = None, use_gpu: bool = True,
verl/single_controller/ray/base.py:51
← previous
next →
401–500 of 858, ranked by callers