MCPcopy Create free account

hub / github.com/JinaLeejnl/AlignX / functions

Functions298 in github.com/JinaLeejnl/AlignX

↓ 77 callersMethodis_rank_0
(self)
train/OpenRLHF/openrlhf/utils/deepspeed.py:404
↓ 72 callersMethodappend
Append experience to replay buffer.
train/OpenRLHF/openrlhf/trainer/ray/ppo_critic.py:166
↓ 40 callersMethodprint
(self, *msg)
train/OpenRLHF/openrlhf/utils/deepspeed.py:400
↓ 23 callersMethodupdate
(self, current, n_steps)
train/OpenRLHF/openrlhf/trainer/ppo_utils/kl_controller.py:30
↓ 19 callersMethodappend
(self, experience: Experience)
train/OpenRLHF/openrlhf/trainer/ppo_utils/replay_buffer.py:175
↓ 18 callersMethod__len__
(self)
train/OpenRLHF/openrlhf/trainer/ppo_utils/replay_buffer.py:199
↓ 18 callersMethodsetup_dataloader
( self, replay_buffer, batch_size: int, pin_memory: bool = False, shuf
train/OpenRLHF/openrlhf/utils/deepspeed.py:143
↓ 17 callersMethodall_reduce
(self, data, op="mean")
train/OpenRLHF/openrlhf/utils/deepspeed.py:362
↓ 15 callersMethodget_rank
(self)
train/OpenRLHF/openrlhf/utils/deepspeed.py:407
↓ 15 callersFunctionget_tokenizer
(pretrain, model, padding_side="left", strategy=None, use_fast=True)
train/OpenRLHF/openrlhf/utils/utils.py:19
↓ 15 callersMethodprepare
( self, *models_or_model_optim_pairs: ModelOrModelOptimPair, is_rlhf=False )
train/OpenRLHF/openrlhf/utils/deepspeed.py:185
↓ 13 callersFunctionblending_datasets
( datasets, probabilities, strategy=None, seed=42, max_count=5000000, return_eval=True
train/OpenRLHF/openrlhf/utils/utils.py:44
↓ 12 callersMethodformat
(self, record)
train/OpenRLHF/openrlhf/utils/logging_utils.py:17
↓ 12 callersMethodget_ds_train_config
(self, is_actor)
train/OpenRLHF/openrlhf/utils/deepspeed.py:221
↓ 11 callersFunctionzero_pad_sequences
(sequences, side: str = "left", value=0)
train/OpenRLHF/openrlhf/datasets/utils.py:6
↓ 10 callersMethodcreate_optimizer
(self, model, **kwargs)
train/OpenRLHF/openrlhf/utils/deepspeed.py:117
↓ 10 callersFunctionget_strategy
(args)
train/OpenRLHF/openrlhf/utils/utils.py:32
↓ 10 callersMethodgradient_checkpointing_enable
(self, gradient_checkpointing_kwargs={"use_reentrant": False})
train/OpenRLHF/openrlhf/models/actor.py:224
↓ 10 callersMethodload_ckpt
( self, model, load_dir, tag=None, load_module_strict=True, lo
train/OpenRLHF/openrlhf/utils/deepspeed.py:443
↓ 10 callersMethodsave_ckpt
(self, model, save_dir, tag=None, max_num=3, max_mem=1000, client_state={}, save_latest=True)
train/OpenRLHF/openrlhf/utils/deepspeed.py:410
↓ 10 callersMethodsetup_distributed
(self, timeout=timedelta(minutes=30))
train/OpenRLHF/openrlhf/utils/deepspeed.py:74
↓ 10 callersMethodtokenizer
(prompt, response)
train/OpenRLHF/openrlhf/datasets/unpaired_preference_dataset.py:109
↓ 9 callersMethodbackward
(self, loss: torch.Tensor, model: nn.Module, optimizer: optim.Optimizer, **kwargs)
train/OpenRLHF/openrlhf/utils/deepspeed.py:126
↓ 9 callersMethodget_ds_eval_config
(self, offload=False)
train/OpenRLHF/openrlhf/utils/deepspeed.py:261
↓ 8 callersMethodoptimizer_step
( self, optimizer: optim.Optimizer, model: nn.Module, scheduler, name=
train/OpenRLHF/openrlhf/utils/deepspeed.py:131
↓ 8 callersMethodsave_model
(self, model: nn.Module, tokenizer, output_dir, **kwargs)
train/OpenRLHF/openrlhf/utils/deepspeed.py:299
↓ 7 callersMethod__init__
(self)
train/OpenRLHF/openrlhf/models/loss.py:243
↓ 7 callersFunctionget_llm_for_sequence_regression
Get transformer with a sequence classification head on top (linear layer). Args: model_name_or_path (str): Path to pretrained model.
train/OpenRLHF/openrlhf/models/model.py:23
↓ 7 callersFunctionmasked_mean
(tensor: torch.Tensor, mask: Optional[torch.Tensor], dim: int = None)
train/OpenRLHF/openrlhf/models/utils.py:85
↓ 7 callersMethodset_epoch
r""" Set the epoch for this sampler. When :attr:`shuffle=True`, this ensures all replicas use a different random ordering for
train/OpenRLHF/openrlhf/utils/distributed_sampler.py:139
↓ 6 callersMethodgenerate
(self, input_ids: torch.Tensor, **kwargs)
train/OpenRLHF/openrlhf/models/actor.py:115
↓ 6 callersFunctioninit_logger
(name: str)
train/OpenRLHF/openrlhf/utils/logging_utils.py:50
↓ 5 callersMethodempty_cache
(self)
train/OpenRLHF/openrlhf/trainer/ray/launcher.py:138
↓ 5 callersFunctionpin_memory
(tensor: Union[torch.Tensor, List[torch.Tensor]])
train/OpenRLHF/openrlhf/trainer/ppo_utils/experience_maker.py:27
↓ 5 callersFunctionto
(tensor: Union[torch.Tensor, List[torch.Tensor]], device)
train/OpenRLHF/openrlhf/trainer/ppo_utils/experience_maker.py:21
↓ 5 callersMethodto_device
(self, device: torch.device)
train/OpenRLHF/openrlhf/trainer/ppo_utils/experience_maker.py:63
↓ 4 callersMethod_setup_distributed
(self, strategy: DeepspeedStrategy)
train/OpenRLHF/openrlhf/trainer/ray/launcher.py:53
↓ 4 callersMethodasync_init_model_from_pretrained
Init model from pretrained checkpoint. Returns: List: list of remote object refs.
train/OpenRLHF/openrlhf/trainer/ray/launcher.py:232
↓ 4 callersMethodcompute_model_logps_with_KL
the front half is matched for spv, the latter half is unmatched for KL
train/OpenRLHF/openrlhf/trainer/kto_trainer.py:266
↓ 4 callersMethodconcatenated_forward
Run the given model on the given batch of inputs, concatenating the chosen and rejected inputs together. We do this to avoid doing two forwar
train/OpenRLHF/openrlhf/trainer/dpo_trainer.py:304
↓ 4 callersFunctionconvert_token_to_id
(token, tokenizer)
train/OpenRLHF/openrlhf/utils/utils.py:128
↓ 4 callersMethodpacked_samples_forward
(self, model, packed_input_ids, packed_attention_masks, packed_seq_lens, prompt_id_lens)
train/OpenRLHF/openrlhf/trainer/dpo_trainer.py:392
↓ 4 callersFunctionunpacking_samples
(values: torch.Tensor, packed_seqlens: List[int])
train/OpenRLHF/openrlhf/models/utils.py:115
↓ 3 callersMethod_unwrap_model
(self, model)
train/OpenRLHF/openrlhf/utils/deepspeed.py:177
↓ 3 callersFunctionremote_rm_fn
remote reward model API api_url: RM API, We assume that the API supports two modes: merging query + response and not merging queries: query+re
train/OpenRLHF/openrlhf/utils/remote_rm_utils.py:32
↓ 3 callersFunctionreset_position_ids
(attention_mask)
train/OpenRLHF/openrlhf/models/utils.py:103
↓ 2 callersMethod_broadcast_to_vllm
(self)
train/OpenRLHF/openrlhf/trainer/ray/ppo_actor.py:147
↓ 2 callersMethod_get_batch_logps
Compute the log probabilities of the given labels under the given logits. Args: logits: Logits of the model (unnormalized). Shape
train/OpenRLHF/openrlhf/trainer/kto_trainer.py:300
↓ 2 callersFunction_is_nightly
()
train/OpenRLHF/setup.py:13
↓ 2 callersFunction_z3_params_to_fetch
(param_list)
train/OpenRLHF/openrlhf/utils/deepspeed_utils.py:111
↓ 2 callersMethodasync_save_model
Save actor model on rank 0. Returns: List: list of remote object refs.
train/OpenRLHF/openrlhf/trainer/ray/launcher.py:303
↓ 2 callersMethodclear
(self)
train/OpenRLHF/openrlhf/trainer/ppo_utils/replay_buffer.py:188
↓ 2 callersFunctioncompute_approx_kl
Compute the approximate KL divergence between two distributions. Schulman blog: http://joschu.net/blog/kl-approx.html Args: log_
train/OpenRLHF/openrlhf/models/utils.py:9
↓ 2 callersMethodconcatenated_forward
Run the given model on the given batch of inputs, concatenating the chosen and rejected inputs together. We do this to avoid doing two forwar
train/OpenRLHF/openrlhf/trainer/rm_trainer.py:312
↓ 2 callersFunctionconvert_ring_attn_params
(sequences, attention_mask, packed_seq_lens, ring_attn_group)
train/OpenRLHF/openrlhf/models/ring_attn_utils.py:63
↓ 2 callersMethodempty_cache
(self)
train/OpenRLHF/openrlhf/trainer/ray/ppo_critic.py:179
↓ 2 callersMethodgenerate_samples
Generate samples and return in batches.
train/OpenRLHF/openrlhf/trainer/ppo_utils/experience_maker.py:236
↓ 2 callersFunctioninit_process_group
( backend: Union[str, Backend] = None, init_method: Optional[str] = None, timeout: Optional[timede
train/OpenRLHF/openrlhf/utils/distributed_util.py:20
↓ 2 callersFunctionmake_experience_batch
(items: List[BufferItem], packing_samples=False)
train/OpenRLHF/openrlhf/trainer/ppo_utils/replay_buffer.py:91
↓ 2 callersMethodmake_experience_list
Make a list of experience with the micro_rollout_batch_size. This method will first calculate the response sequences and rewards for
train/OpenRLHF/openrlhf/trainer/ppo_utils/experience_maker.py:173
↓ 2 callersMethodpacked_samples_forward
(self, model, packed_input_ids, packed_attention_masks, packed_seq_lens)
train/OpenRLHF/openrlhf/trainer/rm_trainer.py:357
↓ 2 callersMethodprocess_sequences
(self, sequences: torch.Tensor, input_len, eos_token_id, pad_token_id)
train/OpenRLHF/openrlhf/models/actor.py:148
↓ 2 callersMethodsample
(self)
train/OpenRLHF/openrlhf/trainer/ppo_utils/replay_buffer.py:192
↓ 2 callersMethodtokenize_fn
(self, texts, max_length, padding=True, device=None)
train/OpenRLHF/openrlhf/trainer/ppo_utils/experience_maker.py:153
↓ 2 callersMethodtraining_step_actor
(self, experience: Experience)
train/OpenRLHF/openrlhf/trainer/ppo_trainer.py:332
↓ 2 callersMethodtraining_step_critic
(self, experience: Experience)
train/OpenRLHF/openrlhf/trainer/ppo_trainer.py:418
↓ 2 callersFunctiontrans_persona
(embedding)
train/profile_utils.py:96
↓ 1 callersMethod__init__
(self, *args, **kwargs)
train/OpenRLHF/openrlhf/trainer/ray/vllm_engine.py:15
↓ 1 callersMethod__init__
( self, actor: Actor, critic: nn.Module, reward_model: nn.Module, init
train/OpenRLHF/openrlhf/trainer/ppo_utils/experience_maker.py:125
↓ 1 callersMethod__init__
(self, config: AutoConfig)
train/OpenRLHF/openrlhf/models/model.py:150
↓ 1 callersMethod_ds_init_eval_model
(self, model)
train/OpenRLHF/openrlhf/utils/deepspeed.py:243
↓ 1 callersMethod_ds_init_train_model
(self, model, optim, scheduler)
train/OpenRLHF/openrlhf/utils/deepspeed.py:202
↓ 1 callersFunction_fetch_package_name
()
train/OpenRLHF/setup.py:39
↓ 1 callersFunction_fetch_readme
()
train/OpenRLHF/setup.py:22
↓ 1 callersFunction_fetch_requirements
(path)
train/OpenRLHF/setup.py:17
↓ 1 callersFunction_fetch_version
()
train/OpenRLHF/setup.py:27
↓ 1 callersMethod_generate_vllm
(self, all_prompts: List[str], **kwargs)
train/OpenRLHF/openrlhf/trainer/ppo_utils/experience_maker.py:613
↓ 1 callersMethod_get_batch_logps
Compute the log probabilities of the given labels under the given logits. Args: logits: Logits of the model (unnormalized). Shape
train/OpenRLHF/openrlhf/trainer/dpo_trainer.py:354
↓ 1 callersFunction_get_critic_model
(base_pretrained_model, base_llm_model, value_head_prefix="value_head", packing_samples=False)
train/OpenRLHF/openrlhf/models/model.py:217
↓ 1 callersMethod_get_current_node_ip
()
train/OpenRLHF/openrlhf/trainer/ray/launcher.py:37
↓ 1 callersMethod_get_free_port
()
train/OpenRLHF/openrlhf/trainer/ray/launcher.py:43
↓ 1 callersFunction_get_reward_model
(base_pretrained_model, base_llm_model, value_head_prefix="value_head", packing_samples=False)
train/OpenRLHF/openrlhf/models/model.py:146
↓ 1 callersMethod_initiate_actors
(self, pg, num_gpus_per_actor)
train/OpenRLHF/openrlhf/trainer/ray/launcher.py:177
↓ 1 callersMethod_packed_get_batch_logps
( self, logits: torch.FloatTensor, labels: torch.LongTensor, attention_mask,
train/OpenRLHF/openrlhf/trainer/dpo_trainer.py:414
↓ 1 callersMethod_save_checkpoint
(self, args, tag, client_states)
train/OpenRLHF/openrlhf/trainer/ppo_trainer.py:504
↓ 1 callersFunction_setup_logger
()
train/OpenRLHF/openrlhf/utils/logging_utils.py:29
↓ 1 callersFunction_validate_args
(args)
train/OpenRLHF/openrlhf/cli/train_ppo_ray.py:25
↓ 1 callersMethodall_gather
(self, data)
train/OpenRLHF/openrlhf/utils/deepspeed.py:385
↓ 1 callersMethodasync_fit_actor_model
Train actor model. Args: critic_model_group (PPORayActorGroup): critic model group. initial_model_group (PPORayActorG
train/OpenRLHF/openrlhf/trainer/ray/launcher.py:244
↓ 1 callersFunctionbatch_generate
(args)
train/OpenRLHF/openrlhf/cli/batch_inference.py:92
↓ 1 callersFunctionbatch_generate_vllm
(args)
train/OpenRLHF/openrlhf/cli/batch_inference.py:16
↓ 1 callersFunctionbatch_rm_inference
(args)
train/OpenRLHF/openrlhf/cli/batch_inference.py:203
↓ 1 callersMethodcompute_model_logps
(self, model, input_ids, attention_mask, labels, prompt_id_lens)
train/OpenRLHF/openrlhf/trainer/kto_trainer.py:289
↓ 1 callersFunctioncompute_reward
( r: Union[torch.Tensor, float], kl_coef: float, kl: Union[torch.Tensor, List[torch.Tensor]],
train/OpenRLHF/openrlhf/models/utils.py:39
↓ 1 callersMethodconcatenated_inputs
Concatenate the chosen and rejected inputs into a single tensor. Args: batch: A batch of data. Must contain the keys 'chosen_inpu
train/OpenRLHF/openrlhf/trainer/rm_trainer.py:324
↓ 1 callersMethodconcatenated_inputs
Concatenate the chosen and rejected inputs into a single tensor. Args: batch: A batch of data. Must contain the keys 'chosen_inpu
train/OpenRLHF/openrlhf/trainer/dpo_trainer.py:322
↓ 1 callersFunctioncreate_vllm_engines
( num_engines: int, tensor_parallel_size: int, pretrain: str, seed: int, enable_prefix_cac
train/OpenRLHF/openrlhf/trainer/ray/vllm_engine.py:76
↓ 1 callersMethodevaluate
(self, eval_dataloader, steps=0)
train/OpenRLHF/openrlhf/trainer/prm_trainer.py:193
↓ 1 callersMethodevaluate
(self, steps=0)
train/OpenRLHF/openrlhf/trainer/kto_trainer.py:209
↓ 1 callersMethodevaluate
(self, eval_dataloader, steps=0)
train/OpenRLHF/openrlhf/trainer/rm_trainer.py:232
next →1–100 of 298, ranked by callers