Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/deepspeedai/DeepSpeed
/ functions
Functions
12,438 in github.com/deepspeedai/DeepSpeed
⨍
Functions
12,438
◇
Types & classes
2,033
↳
Endpoints
45
↓ 938 callers
Function
get_accelerator
()
accelerator/real_accelerator.py:51
↓ 746 callers
Method
append
(self, raw_name, record_name, latency, msg_size)
deepspeed/utils/comms_logging.py:104
↓ 426 callers
Method
parameters
This method should create a generator of tuples of the form (name, parameter) for all parameters in the model. The name should be the
deepspeed/inference/v2/checkpoint/base_engine.py:28
↓ 382 callers
Method
initialize
Create the inference parameter.
deepspeed/inference/v2/inference_parameter.py:56
↓ 263 callers
Method
device_name
(self, device_index=None)
accelerator/hpu_accelerator.py:56
↓ 252 callers
Method
to
(self, *args, **kwargs)
deepspeed/ops/fp_quantizer/quantize.py:100
↓ 238 callers
Method
copy_
(self, other)
tests/unit/v1/zero/test_overlap_comm_record_stream.py:19
↓ 224 callers
Method
get_rank
(self, group=None)
deepspeed/comm/torch.py:511
↓ 222 callers
Method
get_world_size
(self, group=None)
deepspeed/comm/torch.py:514
↓ 219 callers
Method
to
(self, *args, **kwargs)
tests/unit/v1/compile/test_graph_profile.py:206
↓ 217 callers
Method
numel
(self)
deepspeed/checkpoint/affine.py:75
↓ 205 callers
Method
get
Retrieve and materialize stored real inputs Returns: Materialized real inputs with actual tensors Raises:
deepspeed/compile/input_storage.py:165
↓ 190 callers
Method
reshape
(self, target_3d_desc, verbose=False)
deepspeed/checkpoint/reshape_3d_utils.py:27
↓ 179 callers
Method
contiguous
Merge partitioned weights from flat_groups into a single tensor.
deepspeed/utils/zero_to_fp32.py:475
↓ 168 callers
Method
manual_seed
(self, seed)
accelerator/hpu_accelerator.py:88
↓ 163 callers
Method
numel
(self)
deepspeed/runtime/swap_tensor/optimizer_utils.py:60
↓ 150 callers
Method
backward
(ctx, grad_output)
tests/unit/v1/zero/test_zero_activation_checkpoint_lifecycle.py:68
↓ 145 callers
Method
get_rank
Return the global rank of a process via its coordinates. Coordinates are specified as kwargs. For example: >>> X = ProcessTopolo
deepspeed/runtime/pipe/topology.py:49
↓ 135 callers
Method
backward
(ctx, grad)
tests/unit/runtime/zero/test_zero_shared_loss_gradient.py:36
↓ 134 callers
Method
destroy
(self)
deepspeed/runtime/engine.py:1158
↓ 121 callers
Method
data_ptr
csrc/gds/py_lib/deepspeed_gds_op.cpp:109
↓ 121 callers
Function
random_dataloader
(model, total_samples, hidden_dim, device, dtype=preferred_dtype())
tests/unit/simple_model.py:275
↓ 114 callers
Method
is_fp16_supported
(self)
accelerator/hpu_accelerator.py:163
↓ 114 callers
Method
warning
(self, msg)
op_builder/builder.py:538
↓ 110 callers
Method
current_device_name
(self)
tests/unit/v1/zero/test_overlap_comm_record_stream.py:42
↓ 107 callers
Method
size
(self, index)
deepspeed/runtime/data_pipeline/data_sampling/indexed_dataset.py:207
↓ 105 callers
Method
step
(self, step_id, closure=None)
tests/unit/v1/ops/muon/test_muon_partial_training.py:320
↓ 99 callers
Method
device
(self, device_index=None)
accelerator/hpu_accelerator.py:60
↓ 99 callers
Method
size
csrc/adam/cpu_adam_impl.cpp:408
↓ 97 callers
Method
get
Retrieves a single item from the dataset with the option to only return a portion of the item. get(idx) is the same as [idx] but get
deepspeed/runtime/data_pipeline/data_sampling/indexed_dataset.py:532
↓ 93 callers
Method
barrier
(self, group=None, async_op=False, device_ids=None)
deepspeed/comm/ccl.py:137
↓ 93 callers
Method
is_bf16_supported
(self)
accelerator/hpu_accelerator.py:160
↓ 92 callers
Method
current_device_name
(self)
accelerator/hpu_accelerator.py:69
↓ 83 callers
Method
all_reduce
(self, tensor, op=ReduceOp.SUM, group=None, async_op=False)
deepspeed/comm/ccl.py:79
↓ 82 callers
Method
is_initialized
(self)
deepspeed/comm/ccl.py:60
↓ 79 callers
Method
add
(self, b)
deepspeed/runtime/sparse_tensor.py:55
↓ 78 callers
Method
step
(self, closure=None)
tests/unit/runtime/sparse_tensor/test_sparse_grads.py:36
↓ 76 callers
Method
load
(self)
tests/unit/v1/accelerator/test_accelerator.py:259
↓ 67 callers
Function
required_torch_version
(min_version=None, max_version=None)
deepspeed/utils/torch.py:16
↓ 67 callers
Method
update
Update the tuner with what configurations have been evaluated and their performance results
deepspeed/autotuning/tuner/base_tuner.py:35
↓ 65 callers
Method
is_available
(self)
accelerator/hpu_accelerator.py:176
↓ 64 callers
Method
device
(self)
deepspeed/runtime/swap_tensor/optimizer_utils.py:77
↓ 64 callers
Function
preferred_dtype
()
tests/unit/common.py:515
↓ 64 callers
Method
synchronize
(self, device_index=None)
accelerator/hpu_accelerator.py:75
↓ 59 callers
Method
__new__
(cls, data)
tests/unit/v1/compile/test_graph_profile.py:200
↓ 57 callers
Method
start
(self)
deepspeed/utils/timer.py:168
↓ 56 callers
Method
mean
(self)
deepspeed/utils/timer.py:180
↓ 55 callers
Method
dtype
(self)
deepspeed/runtime/swap_tensor/optimizer_utils.py:80
↓ 52 callers
Method
_op
Return torch.ops.deepspeed.<name>, raising clearly if not registered.
op_builder/supa/inference.py:25
↓ 52 callers
Method
full
(self, device=None)
deepspeed/runtime/utils.py:726
↓ 51 callers
Method
apply
(self, module, enable_cuda_graph=True)
deepspeed/module_inject/containers/vae.py:36
↓ 50 callers
Function
get_scalar_param
(param_dict, param_name, param_default_value)
deepspeed/runtime/config_utils.py:193
↓ 50 callers
Method
transpose
(self)
deepspeed/module_inject/containers/base.py:284
↓ 49 callers
Method
get
(self, _guard)
tests/unit/compile/test_zero3_grad_dtype.py:87
↓ 49 callers
Method
new_group
(self, ranks)
deepspeed/comm/ccl.py:154
↓ 48 callers
Method
broadcast
(self, tensor, src, group=None, async_op=False)
deepspeed/comm/ccl.py:94
↓ 47 callers
Method
current_device
(self)
tests/unit/v1/compile/test_list_schedule.py:141
↓ 46 callers
Method
exists
(path)
deepspeed/runtime/data_pipeline/data_sampling/indexed_dataset.py:211
↓ 46 callers
Function
see_memory_usage
(message, force=False)
deepspeed/runtime/utils.py:826
↓ 44 callers
Function
getCurrentCUDAStream
csrc/xpu/adam/multi_tensor_apply.dp.hpp:23
↓ 44 callers
Method
save_checkpoint
Save training checkpoint Arguments: save_dir: Required. Directory for saving the checkpoint tag: Optional. Checkpoint
deepspeed/runtime/engine.py:4984
↓ 42 callers
Method
pin_memory
(self, tensor, make_copy=True, match_shape=True)
accelerator/cpu_accelerator.py:283
↓ 41 callers
Method
load
(self)
deepspeed/ops/transformer/inference/triton/matmul_ext.py:117
↓ 40 callers
Method
stop
(self, **kwargs)
deepspeed/utils/timer.py:174
↓ 39 callers
Method
load_checkpoint
Load training checkpoint Arguments: load_dir: Required. Directory to load the checkpoint from tag: Checkpoin
deepspeed/runtime/engine.py:4499
↓ 38 callers
Function
initialize_distributed
()
tests/unit/v1/zero/test_zero_user_backward.py:102
↓ 38 callers
Method
makedirs
(self, path, exist_ok=False)
deepspeed/runtime/checkpoint_engine/checkpoint_engine.py:35
↓ 38 callers
Method
state_dict
(self)
deepspeed/runtime/lr_schedules.py:696
↓ 37 callers
Function
_ensure_dc_ops
()
tests/unit/v1/compile/test_offload_activation.py:40
↓ 37 callers
Method
current_device
(self)
accelerator/hpu_accelerator.py:66
↓ 36 callers
Method
current_stream
(self, device_index=None)
accelerator/hpu_accelerator.py:108
↓ 36 callers
Function
log_dist
Log message when get_dist_msg() deems it should be logged, see its docstring for details. Args: message (str) ranks (list)
deepspeed/utils/logging.py:113
↓ 35 callers
Method
all_gather
(self, tensor_list, tensor, group=None, async_op=False)
deepspeed/comm/ccl.py:97
↓ 35 callers
Function
allclose
(x, y, tolerances: Tuple[int, int] = None)
tests/unit/inference/v2/inference_test_utils.py:40
↓ 35 callers
Method
save
(self, name: str, v: Argument, offload)
deepspeed/compile/util.py:212
↓ 34 callers
Method
log
(self, names, normalizer=1.0, reset=True, memory_breakdown=False, ranks=None)
deepspeed/utils/timer.py:192
↓ 34 callers
Method
output
Returns the pre-allocated, padded output Tensor.
deepspeed/inference/v2/modules/interfaces/moe_base.py:79
↓ 34 callers
Method
read
(self, args, tid)
deepspeed/nvme/torch_io.py:23
↓ 33 callers
Method
all_gather_into_tensor
(self, output_tensor, input_tensor, group=None, async_op=False)
deepspeed/comm/ccl.py:111
↓ 33 callers
Method
copy
Copy residency state, optionally starting a candidate-local peak.
deepspeed/compile/list_schedule.py:348
↓ 33 callers
Method
from_pretrained
(*args, **kwargs)
deepspeed/linear/context_manager.py:68
↓ 32 callers
Method
compile
Compile the module using the specified backend and kwargs. If a compiler_fn is set, it will be used instead of torch.compile().
deepspeed/runtime/engine.py:5945
↓ 31 callers
Method
is_rocm_pytorch
()
op_builder/builder.py:206
↓ 31 callers
Method
load
(module, state_dict, prefix)
deepspeed/inference/engine.py:339
↓ 31 callers
Method
stream
(self, stream)
accelerator/hpu_accelerator.py:105
↓ 30 callers
Method
zero_grad
(self)
deepspeed/ops/lion/fused_lion.py:47
↓ 29 callers
Method
all_gather
(param_list=None, async_op=False, hierarchy=0)
deepspeed/runtime/zero/partition_parameters.py:1305
↓ 28 callers
Method
add
Track the rng state.
deepspeed/runtime/activation_checkpointing/checkpointing.py:164
↓ 28 callers
Function
bf16_required_version_check
(accelerator_check=True)
tests/unit/util.py:39
↓ 28 callers
Method
is_pinned
(self, device=None)
tests/unit/v1/compile/test_graph_profile.py:203
↓ 28 callers
Method
write
(self, rel: str, content: str = "")
ci/test_tests_fetcher.py:90
↓ 27 callers
Method
load
(self, name: str)
deepspeed/compile/util.py:215
↓ 27 callers
Method
record
(self)
tests/unit/modeling.py:107
↓ 27 callers
Method
supported_dtypes
(self)
accelerator/hpu_accelerator.py:169
↓ 27 callers
Method
wait
(self)
deepspeed/comm/torch.py:110
↓ 26 callers
Method
empty_cache
(self)
accelerator/hpu_accelerator.py:120
↓ 26 callers
Method
load
(module, state_dict, prefix, mp_group=None)
deepspeed/module_inject/auto_tp.py:160
↓ 24 callers
Function
get_caller_func
(frame=3)
deepspeed/utils/comms_logging.py:10
↓ 24 callers
Function
hasKey
csrc/includes/deepcompile.h:33
↓ 24 callers
Function
safe_get_full_grad
Assemble and return the fp32 gradient of a low-precision (e.g., fp16) parameter. The return data type is that used for gradient accum
deepspeed/utils/tensor_fragment.py:207
next →
1–100 of 12,438, ranked by callers