MCPcopy Create free account

hub / github.com/deepspeedai/DeepSpeed / functions

Functions12,438 in github.com/deepspeedai/DeepSpeed

↓ 938 callersFunctionget_accelerator
()
accelerator/real_accelerator.py:51
↓ 746 callersMethodappend
(self, raw_name, record_name, latency, msg_size)
deepspeed/utils/comms_logging.py:104
↓ 426 callersMethodparameters
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 callersMethodinitialize
Create the inference parameter.
deepspeed/inference/v2/inference_parameter.py:56
↓ 263 callersMethoddevice_name
(self, device_index=None)
accelerator/hpu_accelerator.py:56
↓ 252 callersMethodto
(self, *args, **kwargs)
deepspeed/ops/fp_quantizer/quantize.py:100
↓ 238 callersMethodcopy_
(self, other)
tests/unit/v1/zero/test_overlap_comm_record_stream.py:19
↓ 224 callersMethodget_rank
(self, group=None)
deepspeed/comm/torch.py:511
↓ 222 callersMethodget_world_size
(self, group=None)
deepspeed/comm/torch.py:514
↓ 219 callersMethodto
(self, *args, **kwargs)
tests/unit/v1/compile/test_graph_profile.py:206
↓ 217 callersMethodnumel
(self)
deepspeed/checkpoint/affine.py:75
↓ 205 callersMethodget
Retrieve and materialize stored real inputs Returns: Materialized real inputs with actual tensors Raises:
deepspeed/compile/input_storage.py:165
↓ 190 callersMethodreshape
(self, target_3d_desc, verbose=False)
deepspeed/checkpoint/reshape_3d_utils.py:27
↓ 179 callersMethodcontiguous
Merge partitioned weights from flat_groups into a single tensor.
deepspeed/utils/zero_to_fp32.py:475
↓ 168 callersMethodmanual_seed
(self, seed)
accelerator/hpu_accelerator.py:88
↓ 163 callersMethodnumel
(self)
deepspeed/runtime/swap_tensor/optimizer_utils.py:60
↓ 150 callersMethodbackward
(ctx, grad_output)
tests/unit/v1/zero/test_zero_activation_checkpoint_lifecycle.py:68
↓ 145 callersMethodget_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 callersMethodbackward
(ctx, grad)
tests/unit/runtime/zero/test_zero_shared_loss_gradient.py:36
↓ 134 callersMethoddestroy
(self)
deepspeed/runtime/engine.py:1158
↓ 121 callersMethoddata_ptr
csrc/gds/py_lib/deepspeed_gds_op.cpp:109
↓ 121 callersFunctionrandom_dataloader
(model, total_samples, hidden_dim, device, dtype=preferred_dtype())
tests/unit/simple_model.py:275
↓ 114 callersMethodis_fp16_supported
(self)
accelerator/hpu_accelerator.py:163
↓ 114 callersMethodwarning
(self, msg)
op_builder/builder.py:538
↓ 110 callersMethodcurrent_device_name
(self)
tests/unit/v1/zero/test_overlap_comm_record_stream.py:42
↓ 107 callersMethodsize
(self, index)
deepspeed/runtime/data_pipeline/data_sampling/indexed_dataset.py:207
↓ 105 callersMethodstep
(self, step_id, closure=None)
tests/unit/v1/ops/muon/test_muon_partial_training.py:320
↓ 99 callersMethoddevice
(self, device_index=None)
accelerator/hpu_accelerator.py:60
↓ 99 callersMethodsize
csrc/adam/cpu_adam_impl.cpp:408
↓ 97 callersMethodget
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 callersMethodbarrier
(self, group=None, async_op=False, device_ids=None)
deepspeed/comm/ccl.py:137
↓ 93 callersMethodis_bf16_supported
(self)
accelerator/hpu_accelerator.py:160
↓ 92 callersMethodcurrent_device_name
(self)
accelerator/hpu_accelerator.py:69
↓ 83 callersMethodall_reduce
(self, tensor, op=ReduceOp.SUM, group=None, async_op=False)
deepspeed/comm/ccl.py:79
↓ 82 callersMethodis_initialized
(self)
deepspeed/comm/ccl.py:60
↓ 79 callersMethodadd
(self, b)
deepspeed/runtime/sparse_tensor.py:55
↓ 78 callersMethodstep
(self, closure=None)
tests/unit/runtime/sparse_tensor/test_sparse_grads.py:36
↓ 76 callersMethodload
(self)
tests/unit/v1/accelerator/test_accelerator.py:259
↓ 67 callersFunctionrequired_torch_version
(min_version=None, max_version=None)
deepspeed/utils/torch.py:16
↓ 67 callersMethodupdate
Update the tuner with what configurations have been evaluated and their performance results
deepspeed/autotuning/tuner/base_tuner.py:35
↓ 65 callersMethodis_available
(self)
accelerator/hpu_accelerator.py:176
↓ 64 callersMethoddevice
(self)
deepspeed/runtime/swap_tensor/optimizer_utils.py:77
↓ 64 callersFunctionpreferred_dtype
()
tests/unit/common.py:515
↓ 64 callersMethodsynchronize
(self, device_index=None)
accelerator/hpu_accelerator.py:75
↓ 59 callersMethod__new__
(cls, data)
tests/unit/v1/compile/test_graph_profile.py:200
↓ 57 callersMethodstart
(self)
deepspeed/utils/timer.py:168
↓ 56 callersMethodmean
(self)
deepspeed/utils/timer.py:180
↓ 55 callersMethoddtype
(self)
deepspeed/runtime/swap_tensor/optimizer_utils.py:80
↓ 52 callersMethod_op
Return torch.ops.deepspeed.<name>, raising clearly if not registered.
op_builder/supa/inference.py:25
↓ 52 callersMethodfull
(self, device=None)
deepspeed/runtime/utils.py:726
↓ 51 callersMethodapply
(self, module, enable_cuda_graph=True)
deepspeed/module_inject/containers/vae.py:36
↓ 50 callersFunctionget_scalar_param
(param_dict, param_name, param_default_value)
deepspeed/runtime/config_utils.py:193
↓ 50 callersMethodtranspose
(self)
deepspeed/module_inject/containers/base.py:284
↓ 49 callersMethodget
(self, _guard)
tests/unit/compile/test_zero3_grad_dtype.py:87
↓ 49 callersMethodnew_group
(self, ranks)
deepspeed/comm/ccl.py:154
↓ 48 callersMethodbroadcast
(self, tensor, src, group=None, async_op=False)
deepspeed/comm/ccl.py:94
↓ 47 callersMethodcurrent_device
(self)
tests/unit/v1/compile/test_list_schedule.py:141
↓ 46 callersMethodexists
(path)
deepspeed/runtime/data_pipeline/data_sampling/indexed_dataset.py:211
↓ 46 callersFunctionsee_memory_usage
(message, force=False)
deepspeed/runtime/utils.py:826
↓ 44 callersFunctiongetCurrentCUDAStream
csrc/xpu/adam/multi_tensor_apply.dp.hpp:23
↓ 44 callersMethodsave_checkpoint
Save training checkpoint Arguments: save_dir: Required. Directory for saving the checkpoint tag: Optional. Checkpoint
deepspeed/runtime/engine.py:4984
↓ 42 callersMethodpin_memory
(self, tensor, make_copy=True, match_shape=True)
accelerator/cpu_accelerator.py:283
↓ 41 callersMethodload
(self)
deepspeed/ops/transformer/inference/triton/matmul_ext.py:117
↓ 40 callersMethodstop
(self, **kwargs)
deepspeed/utils/timer.py:174
↓ 39 callersMethodload_checkpoint
Load training checkpoint Arguments: load_dir: Required. Directory to load the checkpoint from tag: Checkpoin
deepspeed/runtime/engine.py:4499
↓ 38 callersFunctioninitialize_distributed
()
tests/unit/v1/zero/test_zero_user_backward.py:102
↓ 38 callersMethodmakedirs
(self, path, exist_ok=False)
deepspeed/runtime/checkpoint_engine/checkpoint_engine.py:35
↓ 38 callersMethodstate_dict
(self)
deepspeed/runtime/lr_schedules.py:696
↓ 37 callersFunction_ensure_dc_ops
()
tests/unit/v1/compile/test_offload_activation.py:40
↓ 37 callersMethodcurrent_device
(self)
accelerator/hpu_accelerator.py:66
↓ 36 callersMethodcurrent_stream
(self, device_index=None)
accelerator/hpu_accelerator.py:108
↓ 36 callersFunctionlog_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 callersMethodall_gather
(self, tensor_list, tensor, group=None, async_op=False)
deepspeed/comm/ccl.py:97
↓ 35 callersFunctionallclose
(x, y, tolerances: Tuple[int, int] = None)
tests/unit/inference/v2/inference_test_utils.py:40
↓ 35 callersMethodsave
(self, name: str, v: Argument, offload)
deepspeed/compile/util.py:212
↓ 34 callersMethodlog
(self, names, normalizer=1.0, reset=True, memory_breakdown=False, ranks=None)
deepspeed/utils/timer.py:192
↓ 34 callersMethodoutput
Returns the pre-allocated, padded output Tensor.
deepspeed/inference/v2/modules/interfaces/moe_base.py:79
↓ 34 callersMethodread
(self, args, tid)
deepspeed/nvme/torch_io.py:23
↓ 33 callersMethodall_gather_into_tensor
(self, output_tensor, input_tensor, group=None, async_op=False)
deepspeed/comm/ccl.py:111
↓ 33 callersMethodcopy
Copy residency state, optionally starting a candidate-local peak.
deepspeed/compile/list_schedule.py:348
↓ 33 callersMethodfrom_pretrained
(*args, **kwargs)
deepspeed/linear/context_manager.py:68
↓ 32 callersMethodcompile
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 callersMethodis_rocm_pytorch
()
op_builder/builder.py:206
↓ 31 callersMethodload
(module, state_dict, prefix)
deepspeed/inference/engine.py:339
↓ 31 callersMethodstream
(self, stream)
accelerator/hpu_accelerator.py:105
↓ 30 callersMethodzero_grad
(self)
deepspeed/ops/lion/fused_lion.py:47
↓ 29 callersMethodall_gather
(param_list=None, async_op=False, hierarchy=0)
deepspeed/runtime/zero/partition_parameters.py:1305
↓ 28 callersMethodadd
Track the rng state.
deepspeed/runtime/activation_checkpointing/checkpointing.py:164
↓ 28 callersFunctionbf16_required_version_check
(accelerator_check=True)
tests/unit/util.py:39
↓ 28 callersMethodis_pinned
(self, device=None)
tests/unit/v1/compile/test_graph_profile.py:203
↓ 28 callersMethodwrite
(self, rel: str, content: str = "")
ci/test_tests_fetcher.py:90
↓ 27 callersMethodload
(self, name: str)
deepspeed/compile/util.py:215
↓ 27 callersMethodrecord
(self)
tests/unit/modeling.py:107
↓ 27 callersMethodsupported_dtypes
(self)
accelerator/hpu_accelerator.py:169
↓ 27 callersMethodwait
(self)
deepspeed/comm/torch.py:110
↓ 26 callersMethodempty_cache
(self)
accelerator/hpu_accelerator.py:120
↓ 26 callersMethodload
(module, state_dict, prefix, mp_group=None)
deepspeed/module_inject/auto_tp.py:160
↓ 24 callersFunctionget_caller_func
(frame=3)
deepspeed/utils/comms_logging.py:10
↓ 24 callersFunctionhasKey
csrc/includes/deepcompile.h:33
↓ 24 callersFunctionsafe_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