Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/deepspeedai/DeepSpeed
/ functions
Functions
10,922 in github.com/deepspeedai/DeepSpeed
⨍
Functions
10,922
◇
Types & classes
1,850
↳
Endpoints
34
↓ 2 callers
Method
_generate
(self, model, tokenizer, prompt)
tests/unit/hybrid_engine/test_he_all.py:31
↓ 2 callers
Function
_get_aio_latencies
csrc/aio/common/deepspeed_aio_common.cpp:60
↓ 2 callers
Function
_get_checkpoint_files
(checkpoint_dir, glob_pattern)
deepspeed/checkpoint/ds_to_universal.py:721
↓ 2 callers
Method
_get_checkpoint_value
(self, key)
deepspeed/checkpoint/deepspeed_checkpoint.py:159
↓ 2 callers
Function
_get_compatible_gpus_v01
We use two heuristics to compute the batch size 1. We use the Lowest Common Multiple of the micro-batches as the base batch size and scale
deepspeed/elasticity/elasticity.py:83
↓ 2 callers
Method
_get_current_buffer
(self)
deepspeed/runtime/swap_tensor/async_swapper.py:162
↓ 2 callers
Function
_get_data_parallel_world_size
Return world size for the data parallel group.
deepspeed/utils/groups.py:771
↓ 2 callers
Method
_get_expert_ckpt_name
(checkpoints_path, layer_id, expert_id, tag, mpu=None)
deepspeed/runtime/engine.py:4055
↓ 2 callers
Function
_get_expert_parallel_ranks
Generate expert parallel and expert data parallel group ranks list. Example - E + M + D parallel world_size = 16 model_degree
deepspeed/utils/groups.py:472
↓ 2 callers
Function
_get_expert_weight
Get expert weight tensor by name, handling both attribute and child module patterns.
deepspeed/moe/ep_repack.py:259
↓ 2 callers
Method
_get_fixture_kwargs
(self, request, func)
tests/unit/common.py:166
↓ 2 callers
Method
_get_flattened_partition
(self, all_partition_states, group=None)
deepspeed/runtime/zero/stage3.py:3168
↓ 2 callers
Method
_get_lean_tensors
(self, padded_flattened_tensor, group_tensors, paddings)
deepspeed/runtime/zero/stage3.py:3038
↓ 2 callers
Function
_get_mem_usage_out_of_torch
()
deepspeed/compile/profilers/graph_profile.py:113
↓ 2 callers
Method
_get_nvtx_domain
(self, domain)
accelerator/cuda_accelerator.py:235
↓ 2 callers
Method
_get_optimizer_ckpt_name
(self, checkpoints_path, tag, expp_rank)
deepspeed/runtime/engine.py:4048
↓ 2 callers
Method
_get_optimizer_loss_scale
(self)
deepspeed/runtime/engine.py:3448
↓ 2 callers
Function
_get_padded_tensor
(src_tensor, size)
deepspeed/runtime/zero/stage_1_and_2.py:97
↓ 2 callers
Method
_get_parallel_write_for_ddp
(self, dp_world_size, dp_rank)
deepspeed/runtime/model_checkpointing/data_parallel_writer_factory.py:195
↓ 2 callers
Function
_get_param_uc_conversion_meta
Return the conversion-facing view of AutoTP UC metadata for a parameter. AutoTP keeps a single parameter-level metadata object with two roles:
deepspeed/module_inject/layers.py:439
↓ 2 callers
Function
_get_param_uc_restore_meta
Return the restore-facing view of AutoTP UC metadata for a parameter. AutoTP parameter metadata intentionally serves two separate consumers:
deepspeed/checkpoint/universal_checkpoint.py:23
↓ 2 callers
Method
_get_parameter_partitions
(self)
deepspeed/runtime/zero/stage3.py:937
↓ 2 callers
Method
_get_rank_zero_ckpt_name
(self, checkpoints_path, tag, mp_rank, dp_rank, bf16_mode)
deepspeed/runtime/engine.py:4006
↓ 2 callers
Method
_get_scale_factor
(self)
deepspeed/runtime/lr_schedules.py:532
↓ 2 callers
Function
_get_send_recv_group
the group id is always the smaller rank unless its a wrap around
deepspeed/runtime/pipe/p2p.py:161
↓ 2 callers
Method
_get_sub_group_partition_count
(self, sub_group_id)
deepspeed/runtime/zero/stage3.py:606
↓ 2 callers
Method
_get_swap_paths
(self, parameters, num_elems)
deepspeed/runtime/swap_tensor/optimizer_utils.py:397
↓ 2 callers
Function
_get_tag_from_path
(path)
deepspeed/runtime/checkpoint_engine/nebula_checkpoint_engine.py:16
↓ 2 callers
Function
_get_test_write_file
(tmpdir, index)
tests/unit/ops/aio/test_aio.py:52
↓ 2 callers
Method
_get_trainable_parameter_groups
(self)
deepspeed/runtime/zero/stage3.py:645
↓ 2 callers
Function
_get_zero3_model_state_files
(checkpoint_dir)
deepspeed/checkpoint/ds_to_universal.py:700
↓ 2 callers
Method
_git
(self, *args: str)
ci/test_tests_fetcher.py:85
↓ 2 callers
Function
_glm_type_transpose
(input, mp_size)
deepspeed/module_inject/fusedqkv_utils.py:67
↓ 2 callers
Method
_gradient_averaging_world_size
(self, params, partition_world_size)
deepspeed/runtime/zero/stage3.py:640
↓ 2 callers
Method
_group_step_offloaded
Per-parameter selective update for offloaded partitions (CPU or NVMe). NVMe partitions are swapped in, updated, and swapped back out one at a
deepspeed/ops/adam/zenflow_torch_adam.py:506
↓ 2 callers
Function
_has_3d_expert_params
Check if module stores expert weights as 3D parameter tensors (transformers 5.0.0+). Returns True if the module has a parameter named preset.expe
deepspeed/module_inject/auto_ep.py:95
↓ 2 callers
Method
_has_inf_or_nan
(x, j=None)
deepspeed/runtime/zero/stage3.py:2704
↓ 2 callers
Function
_infer_subparam_logical_shapes
(weight_shape, shape, partition_dim, name=None)
deepspeed/module_inject/layers.py:1052
↓ 2 callers
Method
_init
(self, log_level=None)
tests/unit/v1/test_engine_log_level.py:53
↓ 2 callers
Method
_init
(self, gradient_clipping=None)
tests/unit/v1/half_precision/test_gradient_clipping_default.py:50
↓ 2 callers
Function
_init_external_params
(module)
deepspeed/runtime/zero/partition_parameters.py:128
↓ 2 callers
Method
_initialization_checker
Returns whether or not all parameters have been initialized and transformed by the model. Once this returns True, all the `ParameterB
deepspeed/inference/v2/model_implementations/layer_container_base.py:205
↓ 2 callers
Method
_initialize_from_swapped_fp16_params
(self, aio_handle, fp16_partitions_info, fp16_num_elems, fp16_pin
deepspeed/runtime/swap_tensor/optimizer_utils.py:271
↓ 2 callers
Method
_initialize_parameters
(self, parameters, src_tensors, aio_handle)
deepspeed/runtime/swap_tensor/optimizer_utils.py:370
↓ 2 callers
Method
_invalidate_trace
(self)
deepspeed/runtime/zero/partitioned_param_coordinator.py:195
↓ 2 callers
Method
_is_checkpointable
(self, funcs)
deepspeed/runtime/pipe/module.py:664
↓ 2 callers
Function
_is_even
(x)
deepspeed/runtime/pipe/schedule.py:489
↓ 2 callers
Function
_is_expert_model_state_file
(checkpoint_file)
deepspeed/checkpoint/ds_to_universal.py:695
↓ 2 callers
Method
_is_ongoing_drain
(self)
deepspeed/io/double_io_buffer.py:83
↓ 2 callers
Method
_is_test_file
(self, path: Path)
ci/tests_fetcher.py:253
↓ 2 callers
Function
_is_valid_send_recv
(src_stage, dest_stage)
deepspeed/runtime/pipe/p2p.py:37
↓ 2 callers
Function
_key_list_to_string
(key_list)
deepspeed/checkpoint/reshape_utils.py:76
↓ 2 callers
Method
_largest_contiguous
(self)
deepspeed/runtime/zero/contiguous_memory_allocator.py:274
↓ 2 callers
Method
_launch_with_file_store
(self, request, world_size)
tests/unit/common.py:342
↓ 2 callers
Method
_lazy_init_class_dict
(self)
accelerator/hpu_accelerator.py:261
↓ 2 callers
Method
_lazy_init_class_dict
(self)
accelerator/supa_accelerator.py:240
↓ 2 callers
Method
_lazy_init_class_dict
(self)
accelerator/cuda_accelerator.py:341
↓ 2 callers
Method
_link_all_hp_params
(self)
deepspeed/runtime/bf16_optimizer.py:258
↓ 2 callers
Function
_llama3_inverse_frequencies
(config: Any, device: Any)
deepspeed/inference/v2/model_implementations/exaone4_5/model.py:34
↓ 2 callers
Function
_load_torch_checkpoint
(path)
tests/unit/v1/moe/test_autoep_autotp_checkpoint.py:212
↓ 2 callers
Function
_load_universal_file
(universal_dir, param_name, key)
tests/unit/v1/moe/test_autoep_checkpoint.py:54
↓ 2 callers
Method
_make_autoep_folding_metadata
(folding_spec, *, family,
deepspeed/runtime/engine.py:3707
↓ 2 callers
Function
_make_empty_graph_module
()
tests/unit/v1/compile/test_graph_profile.py:79
↓ 2 callers
Function
_make_model
()
tests/unit/v1/moe/test_autoep_grad_parity.py:20
↓ 2 callers
Function
_make_offload_state_key
(key)
deepspeed/runtime/utils.py:1152
↓ 2 callers
Function
_make_zero2_config
()
tests/unit/v1/moe/test_autoep_grad_parity.py:24
↓ 2 callers
Method
_mark_as_occupied
(self, address, size)
deepspeed/runtime/zero/contiguous_memory_allocator.py:280
↓ 2 callers
Method
_matches_glob
(self, rel_posix: str, globs: tuple[str, ...])
ci/tests_fetcher.py:462
↓ 2 callers
Method
_merge_base
Merge-base of ``base`` and ``HEAD``, or "" if it can't be determined. An empty result (e.g. shallow clone that doesn't reach the fork point)
ci/tests_fetcher.py:206
↓ 2 callers
Method
_merge_state_dicts
(self, sd_list)
deepspeed/checkpoint/deepspeed_checkpoint.py:286
↓ 2 callers
Function
_merge_zero_shards
(param_base_path, state, tp_degree, slice_shape=None)
deepspeed/checkpoint/ds_to_universal.py:215
↓ 2 callers
Method
_module_name
Dotted module name for a file under a package root, or None. e.g. deepspeed/runtime/engine.py -> deepspeed.runtime.engine tests/
ci/tests_fetcher.py:283
↓ 2 callers
Function
_no_gather_coalesced
(params: Iterable[Parameter])
deepspeed/runtime/zero/partition_parameters.py:870
↓ 2 callers
Function
_normalize_uc_shape
(value)
deepspeed/module_inject/layers.py:34
↓ 2 callers
Method
_optimizer_step
(self, sub_group_id)
deepspeed/runtime/superoffload/superoffload_stage3.py:91
↓ 2 callers
Function
_pad_rows
(tensor: torch.Tensor, rows: int)
deepspeed/moe/ep_tp_dispatch.py:276
↓ 2 callers
Method
_padding_size
(self, param)
deepspeed/runtime/zero/partition_parameters.py:1599
↓ 2 callers
Function
_params
(engine)
tests/unit/v1/zero/test_zero_coalesce_grad_reduction.py:67
↓ 2 callers
Method
_parse_all
Parse every file once; return (deps_by_file, raw_imports_by_file).
ci/tests_fetcher.py:409
↓ 2 callers
Function
_partition_logical_tensor
(tensor, partition_dim, tp_world_size, tp_index, name=None, subparam_sizes=None)
deepspeed/module_inject/layers.py:1154
↓ 2 callers
Function
_patch_tp_group_creation
(monkeypatch, *, rank=2, initialize_mesh_device=None)
tests/unit/model_parallelism/test_autotp_training.py:41
↓ 2 callers
Method
_pre_all_gather
(self, params, params_buffers=None)
deepspeed/runtime/zero/mics.py:199
↓ 2 callers
Function
_prep_inputs
(*inputs)
tests/unit/runtime/activation_checkpointing/test_activation_checkpointing.py:40
↓ 2 callers
Function
_prime_factors
Returns the prime factorization of positive integer N.
deepspeed/runtime/pipe/topology.py:217
↓ 2 callers
Method
_process_selected_fp32_groups_grad
Process gradients for selected columns in FP32 groups Args: param: The parameter to process param_id: ID of
deepspeed/runtime/zenflow/zenflow_stage_1_and_2.py:254
↓ 2 callers
Function
_prologue
csrc/deepspeed4science/evoformer_attn/gemm/mma_from_smem.h:925
↓ 2 callers
Function
_raise_if_autoep_zero3_partitioned_state
(state_dict)
deepspeed/utils/zero_to_fp32.py:116
↓ 2 callers
Function
_raise_unsupported_load_balance_coeff
(value: object)
deepspeed/module_inject/auto_ep_presets/base.py:19
↓ 2 callers
Method
_reassign_or_swap_out_partitioned_parameters
(self, sub_group_id)
deepspeed/runtime/superoffload/superoffload_stage3.py:114
↓ 2 callers
Function
_reduce
All-reduce the input tensor across model parallel group.
deepspeed/compression/basic_layer.py:620
↓ 2 callers
Method
_reduce_autoep_folding_tp_replicated_gradients
(self)
deepspeed/runtime/engine.py:2781
↓ 2 callers
Method
_reduce_local_output
Reduce (sum) a new local result into the existing local results. Subclasses should override this method. For a given ``out_id``, thi
deepspeed/runtime/zero/tiling.py:170
↓ 2 callers
Function
_ref_apply_rotary
(t, freqs_cos, freqs_sin)
tests/unit/sequence/test_apply_rotary_pos_emb.py:21
↓ 2 callers
Method
_register_deepspeed_module
(self, module, count=[0])
deepspeed/runtime/zero/parameter_offload.py:317
↓ 2 callers
Method
_release_ipg_buffers
(self)
deepspeed/runtime/zero/stage_1_and_2.py:807
↓ 2 callers
Method
_release_swap_buffers
(self, sub_group_id)
deepspeed/runtime/zero/stage3.py:2440
↓ 2 callers
Method
_remove_module_hooks
(self)
deepspeed/runtime/zero/parameter_offload.py:264
↓ 2 callers
Function
_replace_module
(module, policy)
deepspeed/module_inject/replace_module.py:173
↓ 2 callers
Method
_replace_moe_layer_without_retarget
( self, spec: MoELayerSpec, ep_size: int, ep_rank: int, )
deepspeed/module_inject/auto_ep.py:489
↓ 2 callers
Function
_report_aio_statistics
csrc/aio/common/deepspeed_aio_common.cpp:47
← previous
next →
1,301–1,400 of 10,922, ranked by callers