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
compute_timing_metrics
(batch, timing_raw)
verl/trainer/ppo/ray_trainer.py:272
↓ 1 callers
Function
concat_dict_to_str
(dict: Dict, step)
verl/utils/logger/aggregate_logger.py:21
↓ 1 callers
Function
create_huggingface_actor
Args: model_name: actor_override_config_kwargs: Returns:
verl/utils/model.py:58
↓ 1 callers
Function
create_nccl_communicator_in_ray
(rank: int, world_size: int, group_nam
verl/utils/rendezvous/ray_backend.py:47
↓ 1 callers
Method
create_resource_pool
(self)
verl/trainer/ppo/ray_trainer.py:65
↓ 1 callers
Function
create_worker_group_register_center
(name, info)
verl/single_controller/base/register_center/ray.py:28
↓ 1 callers
Method
default_tp_concat_fn
name: name of the parameter param: training parameters infer_params (List[torch.Tensor]): a list of parameters all-gathered f
verl/workers/sharding_manager/megatron_vllm.py:267
↓ 1 callers
Method
dispatch_fn
(x, i, chunks)
verl/protocol.py:623
↓ 1 callers
Function
dispatch_megatron_compute
User passes in dp data. The data is dispatched to all tp/pp ranks with the same dp
verl/single_controller/base/decorator.py:74
↓ 1 callers
Function
dispatch_megatron_pp_as_dp
treat pp as dp.
verl/single_controller/base/decorator.py:161
↓ 1 callers
Method
do_nothing
(self, data)
tests/ray/test_data_transfer.py:44
↓ 1 callers
Function
download_files_distributed
(download_fn)
verl/utils/dataset/rm_dataset.py:27
↓ 1 callers
Function
dump_data
(data, name)
verl/utils/debug/trajectory_tracker.py:69
↓ 1 callers
Function
eval_subject
Evaluate one subject.
eval_kk/main_eval_instruct.py:46
↓ 1 callers
Function
evaluate_equation
Safely evaluate the arithmetic equation using eval() with precautions.
verl/utils/reward_score/countdown.py:44
↓ 1 callers
Method
execute_func_rank_zero
(self, func, *args, **kwargs)
verl/single_controller/base/worker.py:184
↓ 1 callers
Method
execute_with_func_generator
(self, func, *args, **kwargs)
verl/single_controller/base/worker.py:179
↓ 1 callers
Function
extract_reward_from_line
(line)
tests/e2e/check_results.py:20
↓ 1 callers
Function
extract_solution
Extracts the final answer from the model's response string. Args: solution_str: Raw response string from the language model
eval_kk/compute_score.py:4
↓ 1 callers
Function
extract_solution
Extract the equation from the solution string.
verl/utils/reward_score/countdown.py:7
↓ 1 callers
Function
extract_solution
Extracts the final answer from the model's response string. Args: solution_str: Raw response string from the language model
verl/utils/reward_score/kk.py:4
↓ 1 callers
Function
extract_solution
(solution_str, method='strict')
verl/utils/reward_score/gsm8k.py:18
↓ 1 callers
Function
extract_solution
(solution_str)
verl/utils/reward_score/multiply.py:5
↓ 1 callers
Function
extract_solution
(solution_str)
examples/data_preprocess/gsm8k.py:26
↓ 1 callers
Function
extract_solution
(solution_str)
examples/data_preprocess/math_dataset.py:27
↓ 1 callers
Method
fit
(self)
verl/trainer/fsdp_sft_trainer.py:313
↓ 1 callers
Function
fix_a_slash_b
(string)
verl/utils/reward_score/math.py:125
↓ 1 callers
Function
fix_fracs
(string)
verl/utils/reward_score/math.py:93
↓ 1 callers
Function
fix_sqrt
(string)
verl/utils/reward_score/math.py:150
↓ 1 callers
Function
fold_batch_dim
Fold a batch dim from [bsz, xxx] into [new_bsz, bsz // new_bsz, xxx]
verl/protocol.py:104
↓ 1 callers
Method
foo
(self, wait_time)
tests/ray/check_worker_alive/main.py:33
↓ 1 callers
Method
foo_all_to_all
(self, x, y)
tests/ray/test_worker_group_basics.py:60
↓ 1 callers
Method
foo_custom
(self, x, y)
tests/ray/test_worker_group_basics.py:64
↓ 1 callers
Method
foo_one_to_all
(self, x, y)
tests/ray/test_worker_group_basics.py:56
↓ 1 callers
Method
foo_rank_zero
(self, x, y)
tests/ray/test_worker_group_basics.py:52
↓ 1 callers
Method
format_example
(self, test_records, idx, model_name=None)
eval_kk/kk_processor.py:154
↓ 1 callers
Method
forward
(self, *inputs, **kwargs)
verl/workers/sharding_manager/megatron_vllm.py:127
↓ 1 callers
Method
forward_batch
We assume: - The model takes input: (input_ids, attention_mask, position_ids). No rmpad for the input - The communication sha
verl/workers/reward_model/megatron/reward_model.py:185
↓ 1 callers
Function
func_generator
(self, method_name, dispatch_fn, collect_fn, execute_fn, blocking)
verl/single_controller/ray/base.py:36
↓ 1 callers
Function
gather_from_labels
Gather the label from data. The value in label should be [0, vocab_size) Args: data: (..., vocab_size) label (torch.IntTensor) :
verl/utils/torch_functional.py:34
↓ 1 callers
Function
gen_dataset
( N, DIGIT, LESS_OR_EQUAL=True, )
examples/data_preprocess/multiply.py:29
↓ 1 callers
Function
gen_dataset
any score <0.4 is ok, since +- is easy the model have
examples/data_preprocess/arth.py:29
↓ 1 callers
Function
generate_function
(name)
verl/single_controller/ray/base.py:395
↓ 1 callers
Function
generate_ground_truth_response
Generate ground truth response given a prompt.
tests/e2e/envs/digit_completion/task.py:117
↓ 1 callers
Function
generate_rl_dataset
(target_hdfs_path_dir, local_dir='~/data/full_hh_rlhf/rl')
examples/data_preprocess/full_hh_rlhf.py:86
↓ 1 callers
Function
generate_rm_dataset
(target_hdfs_path_dir, local_dir='~/data/full_hh_rlh/rm')
examples/data_preprocess/full_hh_rlhf.py:58
↓ 1 callers
Function
generate_sft_dataset
(target_hdfs_path_dir, local_dir='~/data/full_hh_rlh/sft')
examples/data_preprocess/full_hh_rlhf.py:30
↓ 1 callers
Method
get_all_prompts
(self)
tests/e2e/envs/digit_completion/task.py:81
↓ 1 callers
Function
get_aux_metrics
(self, test_proto)
tests/ray/test_driverfunc_to_worker.py:42
↓ 1 callers
Method
get_availale_master_addr_port
(self)
verl/single_controller/base/worker.py:63
↓ 1 callers
Method
get_config
(self)
tests/e2e/envs/digit_completion/tokenizer.py:132
↓ 1 callers
Function
get_default_model_parallel_config
()
verl/utils/megatron/tensor_parallel.py:43
↓ 1 callers
Function
get_device_flops
(unit="T")
verl/utils/flops_counter.py:21
↓ 1 callers
Function
get_gsm8k_data
()
tests/verl/utils/dataset/test_rl_dataset.py:20
↓ 1 callers
Function
get_huggingface_actor_config
(model_name: str, override_config_kwargs=None, trust_remote_code=False)
verl/utils/model.py:47
↓ 1 callers
Function
get_local_temp_path
Return a local temp path that joins cache_dir and basename of hdfs_path Args: hdfs_path: cache_dir: Returns:
verl/utils/fs.py:37
↓ 1 callers
Method
get_megatron_global_info
(self)
verl/single_controller/base/megatron/worker.py:25
↓ 1 callers
Function
get_micro_data_parallel_rank
()
verl/workers/sharding_manager/megatron_vllm.py:427
↓ 1 callers
Function
get_model_size
(model: nn.Module, scale='auto')
verl/utils/model.py:102
↓ 1 callers
Function
get_nccl_id_store_by_name
(name)
verl/utils/rendezvous/ray_backend.py:34
↓ 1 callers
Method
get_partitions
(self)
verl/utils/seqlen_balancing.py:63
↓ 1 callers
Function
get_predefined_dispatch_fn
(dispatch_mode)
verl/single_controller/base/decorator.py:300
↓ 1 callers
Function
get_predefined_execute_fn
Note that here we only asks execute_all and execute_rank_zero to be implemented Leave the choice of how these two functions handle argument '
verl/single_controller/base/decorator.py:350
↓ 1 callers
Function
get_random_string
(length: int)
verl/single_controller/ray/base.py:29
↓ 1 callers
Function
get_rm_data
()
tests/verl/utils/dataset/test_rm_dataset.py:21
↓ 1 callers
Function
get_subjects_to_eval
Get subjects to evaluate.
eval_kk/main_eval_instruct.py:125
↓ 1 callers
Method
get_supported_archs
()
verl/models/registry.py:65
↓ 1 callers
Function
get_ulysses_sequence_parallel_rank
Get ulysses sequence parallel rank.
verl/utils/ulysses.py:53
↓ 1 callers
Function
get_weight_loader
(arch: str)
verl/models/weight_loader_registry.py:16
↓ 1 callers
Method
init_megatron
(self, default_megatron_kwargs: Optional[Dict] = None)
verl/single_controller/ray/megatron.py:58
↓ 1 callers
Method
init_model
(self)
tests/ray/detached_worker/server.py:73
↓ 1 callers
Function
init_seed
Initialize random seeds for reproducibility.
eval_kk/main_eval_instruct.py:27
↓ 1 callers
Function
is_equiv
(str1, str2, verbose=False)
verl/utils/reward_score/math.py:32
↓ 1 callers
Function
is_megatron_core_available
()
verl/utils/import_utils.py:24
↓ 1 callers
Function
is_transformers_version_in_range
(min_version: str, max_version: str)
verl/models/transformers/monkey_patch.py:66
↓ 1 callers
Function
karmarkar_karp
(seqlen_list: List[int], k_partitions: int, equal_size: bool)
verl/utils/seqlen_balancing.py:25
↓ 1 callers
Function
levenshtein
(s1, s2)
tests/rollout/test_vllm_hf_loader.py:30
↓ 1 callers
Function
load_eval_records
Load evaluation records based on arguments.
eval_kk/main_eval_instruct.py:36
↓ 1 callers
Method
load_from_disk
(filepath)
verl/protocol.py:220
↓ 1 callers
Function
load_jsonl
Load data from a JSONL file.
eval_kk/main_eval_instruct.py:14
↓ 1 callers
Function
load_limited_test_records
Load limited test records based on given arguments.
eval_kk/main_eval_instruct.py:99
↓ 1 callers
Function
load_megatron_param_and_grad
(module_list: nn.ModuleList, device_id, load_grad=False, hybrid_engine=None)
verl/utils/megatron_utils.py:241
↓ 1 callers
Method
load_model_cls
(model_arch: str, value=False)
verl/models/registry.py:49
↓ 1 callers
Method
load_params_to_cuda
(self)
verl/workers/reward_model/megatron/reward_model.py:270
↓ 1 callers
Function
load_previous_acc_results
Load previous accuracy results.
eval_kk/main_eval_instruct.py:117
↓ 1 callers
Function
log_probs_from_logits_response
Compute the response log_probs from full logits. Note that logits = model(input_ids) Args: input_ids: [batch_size, seqlen] lo
verl/utils/torch_functional.py:284
↓ 1 callers
Function
log_probs_from_logits_response_rmpad
Compute the log_probs from logits with rmpad logits and pad input. Note that logits_rmpad = model(input_ids_rmpad). For each sentences, there is a
verl/utils/torch_functional.py:300
↓ 1 callers
Function
log_seqlen_unbalance
(seqlen_list: List[int], partitions: List[List[int]], prefix)
verl/utils/seqlen_balancing.py:186
↓ 1 callers
Function
logprobs_from_logits_flash_attn
(logits, labels)
verl/utils/torch_functional.py:65
↓ 1 callers
Function
main
(args)
eval_kk/main_eval_instruct.py:140
↓ 1 callers
Function
main
()
tests/rollout/run_fsdp_vllm.py:27
↓ 1 callers
Function
main
(config)
tests/e2e/arithmetic_sequence/rl/main_trainer.py:92
↓ 1 callers
Function
main
()
math_eval/test_aime.py:22
↓ 1 callers
Function
main
()
math_eval/test_amc.py:20
↓ 1 callers
Function
main
(config)
verl/trainer/main_ppo.py:100
↓ 1 callers
Function
main
(config)
verl/trainer/main_generation.py:40
↓ 1 callers
Function
main
(config)
verl/trainer/main_eval.py:37
↓ 1 callers
Function
main
(config)
verl/trainer/fsdp_sft_trainer.py:360
↓ 1 callers
Function
main
(config)
examples/split_placement/main_ppo_split.py:93
↓ 1 callers
Function
make_map_fn
(split)
examples/data_preprocess/full_hh_rlhf.py:93
← previous
next →
301–400 of 858, ranked by callers