Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/deepspeedai/DeepSpeed
/ functions
Functions
11,258 in github.com/deepspeedai/DeepSpeed
⨍
Functions
11,258
◇
Types & classes
1,887
↳
Endpoints
34
↓ 847 callers
Function
get_accelerator
()
accelerator/real_accelerator.py:51
↓ 669 callers
Method
append
(self, raw_name, record_name, latency, msg_size)
deepspeed/utils/comms_logging.py:104
↓ 447 callers
Method
to
(self, *args, **kwargs)
deepspeed/ops/fp_quantizer/quantize.py:100
↓ 357 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
↓ 344 callers
Method
initialize
Create the inference parameter.
deepspeed/inference/v2/inference_parameter.py:56
↓ 340 callers
Method
numel
(self)
deepspeed/runtime/swap_tensor/optimizer_utils.py:60
↓ 242 callers
Method
backward
(ctx, grad_output)
tests/unit/v1/zero/test_zero_activation_checkpoint_lifecycle.py:68
↓ 227 callers
Method
device_name
(self, device_index=None)
accelerator/hpu_accelerator.py:56
↓ 212 callers
Method
get_world_size
(self, group=None)
deepspeed/comm/torch.py:394
↓ 204 callers
Method
copy_
(self, other)
tests/unit/v1/zero/test_overlap_comm_record_stream.py:19
↓ 202 callers
Method
get_rank
(self, group=None)
deepspeed/comm/torch.py:391
↓ 187 callers
Method
step
(self, closure=None)
tests/unit/runtime/sparse_tensor/test_sparse_grads.py:36
↓ 181 callers
Method
get
Retrieve and materialize stored real inputs Returns: Materialized real inputs with actual tensors Raises:
deepspeed/compile/input_storage.py:165
↓ 170 callers
Method
reshape
(self, target_3d_desc, verbose=False)
deepspeed/checkpoint/reshape_3d_utils.py:24
↓ 157 callers
Method
contiguous
Merge partitioned weights from flat_groups into a single tensor.
deepspeed/utils/zero_to_fp32.py:435
↓ 148 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
↓ 131 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
↓ 126 callers
Method
manual_seed
(self, seed)
accelerator/hpu_accelerator.py:88
↓ 125 callers
Method
size
(self, index)
deepspeed/runtime/data_pipeline/data_sampling/indexed_dataset.py:207
↓ 112 callers
Method
warning
(self, msg)
op_builder/builder.py:507
↓ 111 callers
Method
destroy
(self)
deepspeed/runtime/engine.py:826
↓ 108 callers
Method
size
csrc/adam/cpu_adam_impl.cpp:400
↓ 107 callers
Method
data_ptr
csrc/gds/py_lib/deepspeed_gds_op.cpp:109
↓ 91 callers
Method
is_bf16_supported
(self)
accelerator/hpu_accelerator.py:160
↓ 88 callers
Method
all_reduce
(self, tensor, op=ReduceOp.SUM, group=None, async_op=False)
deepspeed/comm/ccl.py:79
↓ 88 callers
Method
barrier
(self, group=None, async_op=False)
deepspeed/comm/ccl.py:137
↓ 88 callers
Method
current_device_name
(self)
accelerator/hpu_accelerator.py:69
↓ 83 callers
Method
is_initialized
(self)
deepspeed/comm/ccl.py:60
↓ 82 callers
Method
device
(self, device_index=None)
accelerator/hpu_accelerator.py:60
↓ 79 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
↓ 69 callers
Function
get_scalar_param
(param_dict, param_name, param_default_value)
deepspeed/runtime/config_utils.py:193
↓ 68 callers
Method
add
(self, b)
deepspeed/runtime/sparse_tensor.py:55
↓ 68 callers
Method
current_device_name
(self)
tests/unit/v1/zero/test_overlap_comm_record_stream.py:42
↓ 66 callers
Function
required_torch_version
(min_version=None, max_version=None)
deepspeed/utils/torch.py:16
↓ 64 callers
Method
load
(self, verbose=False)
op_builder/builder.py:526
↓ 60 callers
Method
device
(self)
deepspeed/runtime/swap_tensor/optimizer_utils.py:77
↓ 59 callers
Method
apply
(self, module, enable_cuda_graph=True)
deepspeed/module_inject/containers/vae.py:36
↓ 59 callers
Method
update
Update the tuner with what configurations have been evaluated and their performance results
deepspeed/autotuning/tuner/base_tuner.py:35
↓ 56 callers
Method
start
(self)
deepspeed/utils/timer.py:168
↓ 55 callers
Method
dtype
(self)
deepspeed/runtime/swap_tensor/optimizer_utils.py:80
↓ 55 callers
Function
preferred_dtype
()
tests/unit/common.py:512
↓ 54 callers
Method
synchronize
(self, device_index=None)
accelerator/hpu_accelerator.py:75
↓ 52 callers
Method
_op
Return torch.ops.deepspeed.<name>, raising clearly if not registered.
op_builder/supa/inference.py:25
↓ 52 callers
Method
current_device
(self)
tests/unit/compile/test_list_schedule.py:286
↓ 51 callers
Method
is_available
(self)
accelerator/hpu_accelerator.py:176
↓ 49 callers
Method
transpose
(self)
deepspeed/module_inject/containers/base.py:284
↓ 46 callers
Method
copy
(self, dst, src, int8=False, allocate_tensor=False)
deepspeed/module_inject/auto_tp.py:100
↓ 46 callers
Method
exists
(path)
deepspeed/runtime/data_pipeline/data_sampling/indexed_dataset.py:211
↓ 46 callers
Method
mean
(self)
deepspeed/utils/timer.py:180
↓ 46 callers
Function
see_memory_usage
(message, force=False)
deepspeed/runtime/utils.py:815
↓ 45 callers
Method
new_group
(self, ranks)
deepspeed/comm/ccl.py:154
↓ 44 callers
Function
getCurrentCUDAStream
csrc/xpu/adam/multi_tensor_apply.dp.hpp:23
↓ 42 callers
Method
save_checkpoint
Save training checkpoint Arguments: save_dir: Required. Directory for saving the checkpoint tag: Optional. Checkpoint
deepspeed/runtime/engine.py:4682
↓ 40 callers
Method
broadcast
(self, tensor, src, group=None, async_op=False)
deepspeed/comm/ccl.py:94
↓ 40 callers
Method
stop
(self, **kwargs)
deepspeed/utils/timer.py:174
↓ 39 callers
Function
initialize_distributed
()
tests/unit/v1/zero/test_zero_user_backward.py:100
↓ 39 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
↓ 38 callers
Method
full
(self, device=None)
deepspeed/runtime/utils.py:715
↓ 36 callers
Method
__new__
(cls, *values)
deepspeed/runtime/config.py:111
↓ 36 callers
Method
load
(self)
deepspeed/ops/transformer/inference/triton/matmul_ext.py:116
↓ 36 callers
Method
makedirs
(self, path, exist_ok=False)
deepspeed/runtime/checkpoint_engine/checkpoint_engine.py:35
↓ 35 callers
Function
allclose
(x, y, tolerances: Tuple[int, int] = None)
tests/unit/inference/v2/inference_test_utils.py:40
↓ 35 callers
Method
current_stream
(self, device_index=None)
accelerator/hpu_accelerator.py:108
↓ 34 callers
Method
communication_backend_name
(self)
accelerator/hpu_accelerator.py:188
↓ 34 callers
Method
log
(self, names, normalizer=1.0, reset=True, memory_breakdown=False, ranks=None)
deepspeed/utils/timer.py:192
↓ 34 callers
Method
read
(self, args, tid)
deepspeed/nvme/torch_io.py:23
↓ 33 callers
Method
pin_memory
(self, tensor, align_bytes=1)
accelerator/hpu_accelerator.py:234
↓ 32 callers
Method
all_gather
(self, tensor_list, tensor, group=None, async_op=False)
deepspeed/comm/ccl.py:97
↓ 32 callers
Method
all_gather_into_tensor
(self, output_tensor, input_tensor, group=None, async_op=False)
deepspeed/comm/ccl.py:111
↓ 32 callers
Method
current_device
(self)
accelerator/hpu_accelerator.py:66
↓ 32 callers
Method
from_pretrained
(*args, **kwargs)
deepspeed/linear/context_manager.py:68
↓ 32 callers
Method
is_rocm_pytorch
()
op_builder/builder.py:185
↓ 32 callers
Method
state_dict
(self)
deepspeed/runtime/lr_schedules.py:658
↓ 31 callers
Method
load
(module, state_dict, prefix)
deepspeed/inference/engine.py:308
↓ 30 callers
Method
stream
(self, stream)
accelerator/hpu_accelerator.py:105
↓ 29 callers
Method
all_gather
(param_list=None, async_op=False, hierarchy=0)
deepspeed/runtime/zero/partition_parameters.py:1278
↓ 29 callers
Method
empty_cache
(self)
accelerator/hpu_accelerator.py:120
↓ 29 callers
Method
load_checkpoint
Load training checkpoint Arguments: load_dir: Required. Directory to load the checkpoint from tag: Checkpoin
deepspeed/runtime/engine.py:4204
↓ 28 callers
Method
load
(module, state_dict, prefix, mp_group=None)
deepspeed/module_inject/auto_tp.py:156
↓ 28 callers
Method
save
(self, name: str, v: Argument, offload)
deepspeed/compile/util.py:212
↓ 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
↓ 26 callers
Method
wait
(self)
deepspeed/comm/torch.py:94
↓ 24 callers
Function
hasKey
csrc/includes/deepcompile.h:33
↓ 24 callers
Method
record
(self)
tests/unit/modeling.py:107
↓ 24 callers
Method
zero_grad
(self)
deepspeed/ops/lion/fused_lion.py:47
↓ 23 callers
Function
_config
(zero_stage, world_size=2, contiguous_gradients=False, overlap_comm=False,
tests/unit/v1/zero/test_zero_coalesce_grad_reduction.py:16
↓ 23 callers
Method
add
Track the rng state.
deepspeed/runtime/activation_checkpointing/checkpointing.py:154
↓ 23 callers
Function
bf16_required_version_check
(accelerator_check=True)
tests/unit/util.py:39
↓ 23 callers
Method
clear
(self)
deepspeed/compile/backend.py:66
↓ 23 callers
Method
get_param_id
(self, param)
deepspeed/runtime/zero/stage3.py:1439
↓ 23 callers
Method
sizes
(self)
deepspeed/runtime/data_pipeline/data_sampling/indexed_dataset.py:546
↓ 23 callers
Method
supported_dtypes
(self)
accelerator/hpu_accelerator.py:169
↓ 22 callers
Method
decode
(self, *inputs, **kwargs)
deepspeed/model_implementations/diffusers/vae.py:56
↓ 22 callers
Function
get_caller_func
(frame=3)
deepspeed/utils/comms_logging.py:10
↓ 22 callers
Method
run
(self)
tests/unit/common.py:155
↓ 22 callers
Method
wait
(self, **kwargs)
tests/unit/runtime/zero/test_zero_context.py:88
↓ 22 callers
Function
z3_leaf_module
Returns whether a module in `model` has been flagged as a 'leaf' module. See `set_z3_leaf_modules` for more details. Args:
deepspeed/utils/z3_leaf_module.py:15
↓ 21 callers
Method
GetCurrentStream
csrc/transformer/inference/includes/inference_context.h:216
next →
1–100 of 11,258, ranked by callers