Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/deepspeedai/DeepSpeed
/ functions
Functions
12,000 in github.com/deepspeedai/DeepSpeed
⨍
Functions
12,000
◇
Types & classes
1,989
↳
Endpoints
37
↓ 935 callers
Function
get_accelerator
()
accelerator/real_accelerator.py:51
↓ 711 callers
Method
append
(self, raw_name, record_name, latency, msg_size)
deepspeed/utils/comms_logging.py:104
↓ 386 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
↓ 367 callers
Method
initialize
Create the inference parameter.
deepspeed/inference/v2/inference_parameter.py:56
↓ 361 callers
Method
numel
(self)
deepspeed/runtime/swap_tensor/optimizer_utils.py:60
↓ 260 callers
Method
to
(self, *args, **kwargs)
deepspeed/ops/fp_quantizer/quantize.py:100
↓ 257 callers
Method
device_name
(self, device_index=None)
accelerator/hpu_accelerator.py:56
↓ 224 callers
Method
copy_
(self, other)
tests/unit/v1/zero/test_overlap_comm_record_stream.py:19
↓ 221 callers
Method
get
Retrieve and materialize stored real inputs Returns: Materialized real inputs with actual tensors Raises:
deepspeed/compile/input_storage.py:165
↓ 220 callers
Method
get_rank
(self, group=None)
deepspeed/comm/torch.py:491
↓ 219 callers
Method
get_world_size
(self, group=None)
deepspeed/comm/torch.py:494
↓ 214 callers
Method
to
(self, *args, **kwargs)
tests/unit/v1/compile/test_graph_profile.py:206
↓ 183 callers
Method
reshape
(self, target_3d_desc, verbose=False)
deepspeed/checkpoint/reshape_3d_utils.py:27
↓ 178 callers
Method
contiguous
Merge partitioned weights from flat_groups into a single tensor.
deepspeed/utils/zero_to_fp32.py:435
↓ 156 callers
Method
backward
(ctx, grad)
tests/unit/runtime/zero/test_zero_shared_loss_gradient.py:36
↓ 152 callers
Method
manual_seed
(self, seed)
accelerator/hpu_accelerator.py:88
↓ 149 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
↓ 134 callers
Function
random_dataloader
(model, total_samples, hidden_dim, device, dtype=preferred_dtype())
tests/unit/simple_model.py:275
↓ 130 callers
Method
is_fp16_supported
(self)
accelerator/hpu_accelerator.py:163
↓ 128 callers
Method
size
(self, index)
deepspeed/runtime/data_pipeline/data_sampling/indexed_dataset.py:207
↓ 125 callers
Method
destroy
(self)
deepspeed/runtime/engine.py:957
↓ 119 callers
Method
backward
(ctx, grad_output)
tests/unit/v1/zero/test_zero_activation_checkpoint_lifecycle.py:68
↓ 119 callers
Method
data_ptr
csrc/gds/py_lib/deepspeed_gds_op.cpp:109
↓ 119 callers
Method
warning
(self, msg)
op_builder/builder.py:528
↓ 110 callers
Method
size
csrc/adam/cpu_adam_impl.cpp:400
↓ 99 callers
Method
current_device_name
(self)
tests/unit/v1/zero/test_overlap_comm_record_stream.py:42
↓ 93 callers
Method
device
(self, device_index=None)
accelerator/hpu_accelerator.py:60
↓ 91 callers
Method
barrier
(self, group=None, async_op=False)
deepspeed/comm/ccl.py:137
↓ 91 callers
Method
current_device_name
(self)
accelerator/hpu_accelerator.py:69
↓ 91 callers
Method
is_bf16_supported
(self)
accelerator/hpu_accelerator.py:160
↓ 90 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
↓ 84 callers
Method
step
(self, step_id, closure=None)
tests/unit/v1/ops/muon/test_muon_partial_training.py:320
↓ 83 callers
Method
step
(self, closure=None)
tests/unit/runtime/sparse_tensor/test_sparse_grads.py:36
↓ 82 callers
Method
all_reduce
(self, tensor, op=ReduceOp.SUM, group=None, async_op=False)
deepspeed/comm/ccl.py:79
↓ 80 callers
Method
is_initialized
(self)
deepspeed/comm/ccl.py:60
↓ 73 callers
Method
load
(self)
tests/unit/v1/accelerator/test_accelerator.py:177
↓ 73 callers
Function
required_torch_version
(min_version=None, max_version=None)
deepspeed/utils/torch.py:16
↓ 70 callers
Method
add
(self, b)
deepspeed/runtime/sparse_tensor.py:55
↓ 70 callers
Function
get_scalar_param
(param_dict, param_name, param_default_value)
deepspeed/runtime/config_utils.py:193
↓ 62 callers
Function
preferred_dtype
()
tests/unit/common.py:515
↓ 62 callers
Method
update
Update the tuner with what configurations have been evaluated and their performance results
deepspeed/autotuning/tuner/base_tuner.py:35
↓ 61 callers
Method
apply
(self, module, enable_cuda_graph=True)
deepspeed/module_inject/containers/vae.py:36
↓ 61 callers
Method
device
(self)
deepspeed/runtime/swap_tensor/optimizer_utils.py:77
↓ 61 callers
Method
synchronize
(self, device_index=None)
accelerator/hpu_accelerator.py:75
↓ 60 callers
Method
is_available
(self)
accelerator/hpu_accelerator.py:176
↓ 56 callers
Method
dtype
(self)
deepspeed/runtime/swap_tensor/optimizer_utils.py:80
↓ 56 callers
Method
start
(self)
deepspeed/utils/timer.py:168
↓ 53 callers
Method
current_device
(self)
tests/unit/v1/compile/test_list_schedule.py:324
↓ 52 callers
Method
_op
Return torch.ops.deepspeed.<name>, raising clearly if not registered.
op_builder/supa/inference.py:25
↓ 52 callers
Method
mean
(self)
deepspeed/utils/timer.py:180
↓ 50 callers
Method
__new__
(cls, data)
tests/unit/v1/compile/test_graph_profile.py:200
↓ 49 callers
Method
broadcast
(self, tensor, src, group=None, async_op=False)
deepspeed/comm/ccl.py:94
↓ 48 callers
Method
transpose
(self)
deepspeed/module_inject/containers/base.py:284
↓ 47 callers
Method
pin_memory
(self, tensor, make_copy=True, match_shape=True)
accelerator/cpu_accelerator.py:281
↓ 46 callers
Method
copy
(self, dst, src, int8=False, allocate_tensor=False)
deepspeed/module_inject/auto_tp.py:103
↓ 46 callers
Method
exists
(path)
deepspeed/runtime/data_pipeline/data_sampling/indexed_dataset.py:211
↓ 46 callers
Method
new_group
(self, ranks)
deepspeed/comm/ccl.py:154
↓ 46 callers
Function
see_memory_usage
(message, force=False)
deepspeed/runtime/utils.py:823
↓ 45 callers
Method
save_checkpoint
Save training checkpoint Arguments: save_dir: Required. Directory for saving the checkpoint tag: Optional. Checkpoint
deepspeed/runtime/engine.py:4859
↓ 44 callers
Function
getCurrentCUDAStream
csrc/xpu/adam/multi_tensor_apply.dp.hpp:23
↓ 42 callers
Method
full
(self, device=None)
deepspeed/runtime/utils.py:723
↓ 41 callers
Method
load
(self)
deepspeed/ops/transformer/inference/triton/matmul_ext.py:116
↓ 41 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
↓ 40 callers
Method
stop
(self, **kwargs)
deepspeed/utils/timer.py:174
↓ 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
↓ 36 callers
Method
current_stream
(self, device_index=None)
accelerator/hpu_accelerator.py:108
↓ 35 callers
Function
allclose
(x, y, tolerances: Tuple[int, int] = None)
tests/unit/inference/v2/inference_test_utils.py:40
↓ 35 callers
Method
load_checkpoint
Load training checkpoint Arguments: load_dir: Required. Directory to load the checkpoint from tag: Checkpoin
deepspeed/runtime/engine.py:4381
↓ 35 callers
Method
read
(self, args, tid)
deepspeed/nvme/torch_io.py:23
↓ 34 callers
Method
all_gather
(self, tensor_list, tensor, group=None, async_op=False)
deepspeed/comm/ccl.py:97
↓ 34 callers
Method
communication_backend_name
(self)
accelerator/hpu_accelerator.py:188
↓ 34 callers
Method
current_device
(self)
accelerator/hpu_accelerator.py:66
↓ 34 callers
Method
log
(self, names, normalizer=1.0, reset=True, memory_breakdown=False, ranks=None)
deepspeed/utils/timer.py:192
↓ 34 callers
Method
state_dict
(self)
deepspeed/runtime/lr_schedules.py:671
↓ 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
from_pretrained
(*args, **kwargs)
deepspeed/linear/context_manager.py:68
↓ 32 callers
Method
is_rocm_pytorch
()
op_builder/builder.py:206
↓ 32 callers
Method
save
(self, name: str, v: Argument, offload)
deepspeed/compile/util.py:212
↓ 32 callers
Method
step
(engine)
tests/unit/compile/test_tp_compile.py:398
↓ 31 callers
Method
load
(module, state_dict, prefix)
deepspeed/inference/engine.py:346
↓ 31 callers
Method
stream
(self, stream)
accelerator/hpu_accelerator.py:105
↓ 30 callers
Function
get_shard_size_list
(total_size, mp_size, name=None, num_kv_heads=None)
deepspeed/module_inject/tp_shard.py:101
↓ 29 callers
Method
all_gather
(param_list=None, async_op=False, hierarchy=0)
deepspeed/runtime/zero/partition_parameters.py:1295
↓ 29 callers
Method
empty_cache
(self)
accelerator/hpu_accelerator.py:120
↓ 29 callers
Method
zero_grad
(self)
deepspeed/ops/lion/fused_lion.py:47
↓ 28 callers
Function
_ensure_dc_ops
()
tests/unit/v1/compile/test_offload_activation.py:39
↓ 28 callers
Function
bf16_required_version_check
(accelerator_check=True)
tests/unit/util.py:39
↓ 28 callers
Method
clear
(self)
deepspeed/compile/backend.py:66
↓ 28 callers
Method
load
(self, name: str)
deepspeed/compile/util.py:215
↓ 28 callers
Method
write
(self, rel: str, content: str = "")
ci/test_tests_fetcher.py:90
↓ 27 callers
Method
wait
(self)
deepspeed/comm/torch.py:94
↓ 26 callers
Method
add
Track the rng state.
deepspeed/runtime/activation_checkpointing/checkpointing.py:164
↓ 26 callers
Method
load
(module, state_dict, prefix, mp_group=None)
deepspeed/module_inject/auto_tp.py:159
↓ 26 callers
Method
record
(self)
tests/unit/modeling.py:107
↓ 25 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:5816
↓ 25 callers
Method
is_pinned
(self, device=None)
tests/unit/v1/compile/test_graph_profile.py:203
↓ 25 callers
Method
output
Returns the pre-allocated, padded output Tensor.
deepspeed/inference/v2/modules/interfaces/moe_base.py:79
↓ 24 callers
Function
hasKey
csrc/includes/deepcompile.h:33
↓ 24 callers
Method
supported_dtypes
(self)
accelerator/hpu_accelerator.py:169
next →
1–100 of 12,000, ranked by callers