MCPcopy Create free account

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

Functions858 in github.com/Unakar/Logic-RL

↓ 1 callersFunctioncompute_timing_metrics
(batch, timing_raw)
verl/trainer/ppo/ray_trainer.py:272
↓ 1 callersFunctionconcat_dict_to_str
(dict: Dict, step)
verl/utils/logger/aggregate_logger.py:21
↓ 1 callersFunctioncreate_huggingface_actor
Args: model_name: actor_override_config_kwargs: Returns:
verl/utils/model.py:58
↓ 1 callersFunctioncreate_nccl_communicator_in_ray
(rank: int, world_size: int, group_nam
verl/utils/rendezvous/ray_backend.py:47
↓ 1 callersMethodcreate_resource_pool
(self)
verl/trainer/ppo/ray_trainer.py:65
↓ 1 callersFunctioncreate_worker_group_register_center
(name, info)
verl/single_controller/base/register_center/ray.py:28
↓ 1 callersMethoddefault_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 callersMethoddispatch_fn
(x, i, chunks)
verl/protocol.py:623
↓ 1 callersFunctiondispatch_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 callersFunctiondispatch_megatron_pp_as_dp
treat pp as dp.
verl/single_controller/base/decorator.py:161
↓ 1 callersMethoddo_nothing
(self, data)
tests/ray/test_data_transfer.py:44
↓ 1 callersFunctiondownload_files_distributed
(download_fn)
verl/utils/dataset/rm_dataset.py:27
↓ 1 callersFunctiondump_data
(data, name)
verl/utils/debug/trajectory_tracker.py:69
↓ 1 callersFunctioneval_subject
Evaluate one subject.
eval_kk/main_eval_instruct.py:46
↓ 1 callersFunctionevaluate_equation
Safely evaluate the arithmetic equation using eval() with precautions.
verl/utils/reward_score/countdown.py:44
↓ 1 callersMethodexecute_func_rank_zero
(self, func, *args, **kwargs)
verl/single_controller/base/worker.py:184
↓ 1 callersMethodexecute_with_func_generator
(self, func, *args, **kwargs)
verl/single_controller/base/worker.py:179
↓ 1 callersFunctionextract_reward_from_line
(line)
tests/e2e/check_results.py:20
↓ 1 callersFunctionextract_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 callersFunctionextract_solution
Extract the equation from the solution string.
verl/utils/reward_score/countdown.py:7
↓ 1 callersFunctionextract_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 callersFunctionextract_solution
(solution_str, method='strict')
verl/utils/reward_score/gsm8k.py:18
↓ 1 callersFunctionextract_solution
(solution_str)
verl/utils/reward_score/multiply.py:5
↓ 1 callersFunctionextract_solution
(solution_str)
examples/data_preprocess/gsm8k.py:26
↓ 1 callersFunctionextract_solution
(solution_str)
examples/data_preprocess/math_dataset.py:27
↓ 1 callersMethodfit
(self)
verl/trainer/fsdp_sft_trainer.py:313
↓ 1 callersFunctionfix_a_slash_b
(string)
verl/utils/reward_score/math.py:125
↓ 1 callersFunctionfix_fracs
(string)
verl/utils/reward_score/math.py:93
↓ 1 callersFunctionfix_sqrt
(string)
verl/utils/reward_score/math.py:150
↓ 1 callersFunctionfold_batch_dim
Fold a batch dim from [bsz, xxx] into [new_bsz, bsz // new_bsz, xxx]
verl/protocol.py:104
↓ 1 callersMethodfoo
(self, wait_time)
tests/ray/check_worker_alive/main.py:33
↓ 1 callersMethodfoo_all_to_all
(self, x, y)
tests/ray/test_worker_group_basics.py:60
↓ 1 callersMethodfoo_custom
(self, x, y)
tests/ray/test_worker_group_basics.py:64
↓ 1 callersMethodfoo_one_to_all
(self, x, y)
tests/ray/test_worker_group_basics.py:56
↓ 1 callersMethodfoo_rank_zero
(self, x, y)
tests/ray/test_worker_group_basics.py:52
↓ 1 callersMethodformat_example
(self, test_records, idx, model_name=None)
eval_kk/kk_processor.py:154
↓ 1 callersMethodforward
(self, *inputs, **kwargs)
verl/workers/sharding_manager/megatron_vllm.py:127
↓ 1 callersMethodforward_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 callersFunctionfunc_generator
(self, method_name, dispatch_fn, collect_fn, execute_fn, blocking)
verl/single_controller/ray/base.py:36
↓ 1 callersFunctiongather_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 callersFunctiongen_dataset
( N, DIGIT, LESS_OR_EQUAL=True, )
examples/data_preprocess/multiply.py:29
↓ 1 callersFunctiongen_dataset
any score <0.4 is ok, since +- is easy the model have
examples/data_preprocess/arth.py:29
↓ 1 callersFunctiongenerate_function
(name)
verl/single_controller/ray/base.py:395
↓ 1 callersFunctiongenerate_ground_truth_response
Generate ground truth response given a prompt.
tests/e2e/envs/digit_completion/task.py:117
↓ 1 callersFunctiongenerate_rl_dataset
(target_hdfs_path_dir, local_dir='~/data/full_hh_rlhf/rl')
examples/data_preprocess/full_hh_rlhf.py:86
↓ 1 callersFunctiongenerate_rm_dataset
(target_hdfs_path_dir, local_dir='~/data/full_hh_rlh/rm')
examples/data_preprocess/full_hh_rlhf.py:58
↓ 1 callersFunctiongenerate_sft_dataset
(target_hdfs_path_dir, local_dir='~/data/full_hh_rlh/sft')
examples/data_preprocess/full_hh_rlhf.py:30
↓ 1 callersMethodget_all_prompts
(self)
tests/e2e/envs/digit_completion/task.py:81
↓ 1 callersFunctionget_aux_metrics
(self, test_proto)
tests/ray/test_driverfunc_to_worker.py:42
↓ 1 callersMethodget_availale_master_addr_port
(self)
verl/single_controller/base/worker.py:63
↓ 1 callersMethodget_config
(self)
tests/e2e/envs/digit_completion/tokenizer.py:132
↓ 1 callersFunctionget_default_model_parallel_config
()
verl/utils/megatron/tensor_parallel.py:43
↓ 1 callersFunctionget_device_flops
(unit="T")
verl/utils/flops_counter.py:21
↓ 1 callersFunctionget_gsm8k_data
()
tests/verl/utils/dataset/test_rl_dataset.py:20
↓ 1 callersFunctionget_huggingface_actor_config
(model_name: str, override_config_kwargs=None, trust_remote_code=False)
verl/utils/model.py:47
↓ 1 callersFunctionget_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 callersMethodget_megatron_global_info
(self)
verl/single_controller/base/megatron/worker.py:25
↓ 1 callersFunctionget_micro_data_parallel_rank
()
verl/workers/sharding_manager/megatron_vllm.py:427
↓ 1 callersFunctionget_model_size
(model: nn.Module, scale='auto')
verl/utils/model.py:102
↓ 1 callersFunctionget_nccl_id_store_by_name
(name)
verl/utils/rendezvous/ray_backend.py:34
↓ 1 callersMethodget_partitions
(self)
verl/utils/seqlen_balancing.py:63
↓ 1 callersFunctionget_predefined_dispatch_fn
(dispatch_mode)
verl/single_controller/base/decorator.py:300
↓ 1 callersFunctionget_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 callersFunctionget_random_string
(length: int)
verl/single_controller/ray/base.py:29
↓ 1 callersFunctionget_rm_data
()
tests/verl/utils/dataset/test_rm_dataset.py:21
↓ 1 callersFunctionget_subjects_to_eval
Get subjects to evaluate.
eval_kk/main_eval_instruct.py:125
↓ 1 callersMethodget_supported_archs
()
verl/models/registry.py:65
↓ 1 callersFunctionget_ulysses_sequence_parallel_rank
Get ulysses sequence parallel rank.
verl/utils/ulysses.py:53
↓ 1 callersFunctionget_weight_loader
(arch: str)
verl/models/weight_loader_registry.py:16
↓ 1 callersMethodinit_megatron
(self, default_megatron_kwargs: Optional[Dict] = None)
verl/single_controller/ray/megatron.py:58
↓ 1 callersMethodinit_model
(self)
tests/ray/detached_worker/server.py:73
↓ 1 callersFunctioninit_seed
Initialize random seeds for reproducibility.
eval_kk/main_eval_instruct.py:27
↓ 1 callersFunctionis_equiv
(str1, str2, verbose=False)
verl/utils/reward_score/math.py:32
↓ 1 callersFunctionis_megatron_core_available
()
verl/utils/import_utils.py:24
↓ 1 callersFunctionis_transformers_version_in_range
(min_version: str, max_version: str)
verl/models/transformers/monkey_patch.py:66
↓ 1 callersFunctionkarmarkar_karp
(seqlen_list: List[int], k_partitions: int, equal_size: bool)
verl/utils/seqlen_balancing.py:25
↓ 1 callersFunctionlevenshtein
(s1, s2)
tests/rollout/test_vllm_hf_loader.py:30
↓ 1 callersFunctionload_eval_records
Load evaluation records based on arguments.
eval_kk/main_eval_instruct.py:36
↓ 1 callersMethodload_from_disk
(filepath)
verl/protocol.py:220
↓ 1 callersFunctionload_jsonl
Load data from a JSONL file.
eval_kk/main_eval_instruct.py:14
↓ 1 callersFunctionload_limited_test_records
Load limited test records based on given arguments.
eval_kk/main_eval_instruct.py:99
↓ 1 callersFunctionload_megatron_param_and_grad
(module_list: nn.ModuleList, device_id, load_grad=False, hybrid_engine=None)
verl/utils/megatron_utils.py:241
↓ 1 callersMethodload_model_cls
(model_arch: str, value=False)
verl/models/registry.py:49
↓ 1 callersMethodload_params_to_cuda
(self)
verl/workers/reward_model/megatron/reward_model.py:270
↓ 1 callersFunctionload_previous_acc_results
Load previous accuracy results.
eval_kk/main_eval_instruct.py:117
↓ 1 callersFunctionlog_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 callersFunctionlog_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 callersFunctionlog_seqlen_unbalance
(seqlen_list: List[int], partitions: List[List[int]], prefix)
verl/utils/seqlen_balancing.py:186
↓ 1 callersFunctionlogprobs_from_logits_flash_attn
(logits, labels)
verl/utils/torch_functional.py:65
↓ 1 callersFunctionmain
(args)
eval_kk/main_eval_instruct.py:140
↓ 1 callersFunctionmain
()
tests/rollout/run_fsdp_vllm.py:27
↓ 1 callersFunctionmain
(config)
tests/e2e/arithmetic_sequence/rl/main_trainer.py:92
↓ 1 callersFunctionmain
()
math_eval/test_aime.py:22
↓ 1 callersFunctionmain
()
math_eval/test_amc.py:20
↓ 1 callersFunctionmain
(config)
verl/trainer/main_ppo.py:100
↓ 1 callersFunctionmain
(config)
verl/trainer/main_generation.py:40
↓ 1 callersFunctionmain
(config)
verl/trainer/main_eval.py:37
↓ 1 callersFunctionmain
(config)
verl/trainer/fsdp_sft_trainer.py:360
↓ 1 callersFunctionmain
(config)
examples/split_placement/main_ppo_split.py:93
↓ 1 callersFunctionmake_map_fn
(split)
examples/data_preprocess/full_hh_rlhf.py:93
← previousnext →301–400 of 858, ranked by callers