MCPcopy Create free account

hub / github.com/deepspeedai/DeepSpeed / functions

Functions12,000 in github.com/deepspeedai/DeepSpeed

↓ 935 callersFunctionget_accelerator
()
accelerator/real_accelerator.py:51
↓ 711 callersMethodappend
(self, raw_name, record_name, latency, msg_size)
deepspeed/utils/comms_logging.py:104
↓ 386 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
↓ 367 callersMethodinitialize
Create the inference parameter.
deepspeed/inference/v2/inference_parameter.py:56
↓ 361 callersMethodnumel
(self)
deepspeed/runtime/swap_tensor/optimizer_utils.py:60
↓ 260 callersMethodto
(self, *args, **kwargs)
deepspeed/ops/fp_quantizer/quantize.py:100
↓ 257 callersMethoddevice_name
(self, device_index=None)
accelerator/hpu_accelerator.py:56
↓ 224 callersMethodcopy_
(self, other)
tests/unit/v1/zero/test_overlap_comm_record_stream.py:19
↓ 221 callersMethodget
Retrieve and materialize stored real inputs Returns: Materialized real inputs with actual tensors Raises:
deepspeed/compile/input_storage.py:165
↓ 220 callersMethodget_rank
(self, group=None)
deepspeed/comm/torch.py:491
↓ 219 callersMethodget_world_size
(self, group=None)
deepspeed/comm/torch.py:494
↓ 214 callersMethodto
(self, *args, **kwargs)
tests/unit/v1/compile/test_graph_profile.py:206
↓ 183 callersMethodreshape
(self, target_3d_desc, verbose=False)
deepspeed/checkpoint/reshape_3d_utils.py:27
↓ 178 callersMethodcontiguous
Merge partitioned weights from flat_groups into a single tensor.
deepspeed/utils/zero_to_fp32.py:435
↓ 156 callersMethodbackward
(ctx, grad)
tests/unit/runtime/zero/test_zero_shared_loss_gradient.py:36
↓ 152 callersMethodmanual_seed
(self, seed)
accelerator/hpu_accelerator.py:88
↓ 149 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
↓ 134 callersFunctionrandom_dataloader
(model, total_samples, hidden_dim, device, dtype=preferred_dtype())
tests/unit/simple_model.py:275
↓ 130 callersMethodis_fp16_supported
(self)
accelerator/hpu_accelerator.py:163
↓ 128 callersMethodsize
(self, index)
deepspeed/runtime/data_pipeline/data_sampling/indexed_dataset.py:207
↓ 125 callersMethoddestroy
(self)
deepspeed/runtime/engine.py:957
↓ 119 callersMethodbackward
(ctx, grad_output)
tests/unit/v1/zero/test_zero_activation_checkpoint_lifecycle.py:68
↓ 119 callersMethoddata_ptr
csrc/gds/py_lib/deepspeed_gds_op.cpp:109
↓ 119 callersMethodwarning
(self, msg)
op_builder/builder.py:528
↓ 110 callersMethodsize
csrc/adam/cpu_adam_impl.cpp:400
↓ 99 callersMethodcurrent_device_name
(self)
tests/unit/v1/zero/test_overlap_comm_record_stream.py:42
↓ 93 callersMethoddevice
(self, device_index=None)
accelerator/hpu_accelerator.py:60
↓ 91 callersMethodbarrier
(self, group=None, async_op=False)
deepspeed/comm/ccl.py:137
↓ 91 callersMethodcurrent_device_name
(self)
accelerator/hpu_accelerator.py:69
↓ 91 callersMethodis_bf16_supported
(self)
accelerator/hpu_accelerator.py:160
↓ 90 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
↓ 84 callersMethodstep
(self, step_id, closure=None)
tests/unit/v1/ops/muon/test_muon_partial_training.py:320
↓ 83 callersMethodstep
(self, closure=None)
tests/unit/runtime/sparse_tensor/test_sparse_grads.py:36
↓ 82 callersMethodall_reduce
(self, tensor, op=ReduceOp.SUM, group=None, async_op=False)
deepspeed/comm/ccl.py:79
↓ 80 callersMethodis_initialized
(self)
deepspeed/comm/ccl.py:60
↓ 73 callersMethodload
(self)
tests/unit/v1/accelerator/test_accelerator.py:177
↓ 73 callersFunctionrequired_torch_version
(min_version=None, max_version=None)
deepspeed/utils/torch.py:16
↓ 70 callersMethodadd
(self, b)
deepspeed/runtime/sparse_tensor.py:55
↓ 70 callersFunctionget_scalar_param
(param_dict, param_name, param_default_value)
deepspeed/runtime/config_utils.py:193
↓ 62 callersFunctionpreferred_dtype
()
tests/unit/common.py:515
↓ 62 callersMethodupdate
Update the tuner with what configurations have been evaluated and their performance results
deepspeed/autotuning/tuner/base_tuner.py:35
↓ 61 callersMethodapply
(self, module, enable_cuda_graph=True)
deepspeed/module_inject/containers/vae.py:36
↓ 61 callersMethoddevice
(self)
deepspeed/runtime/swap_tensor/optimizer_utils.py:77
↓ 61 callersMethodsynchronize
(self, device_index=None)
accelerator/hpu_accelerator.py:75
↓ 60 callersMethodis_available
(self)
accelerator/hpu_accelerator.py:176
↓ 56 callersMethoddtype
(self)
deepspeed/runtime/swap_tensor/optimizer_utils.py:80
↓ 56 callersMethodstart
(self)
deepspeed/utils/timer.py:168
↓ 53 callersMethodcurrent_device
(self)
tests/unit/v1/compile/test_list_schedule.py:324
↓ 52 callersMethod_op
Return torch.ops.deepspeed.<name>, raising clearly if not registered.
op_builder/supa/inference.py:25
↓ 52 callersMethodmean
(self)
deepspeed/utils/timer.py:180
↓ 50 callersMethod__new__
(cls, data)
tests/unit/v1/compile/test_graph_profile.py:200
↓ 49 callersMethodbroadcast
(self, tensor, src, group=None, async_op=False)
deepspeed/comm/ccl.py:94
↓ 48 callersMethodtranspose
(self)
deepspeed/module_inject/containers/base.py:284
↓ 47 callersMethodpin_memory
(self, tensor, make_copy=True, match_shape=True)
accelerator/cpu_accelerator.py:281
↓ 46 callersMethodcopy
(self, dst, src, int8=False, allocate_tensor=False)
deepspeed/module_inject/auto_tp.py:103
↓ 46 callersMethodexists
(path)
deepspeed/runtime/data_pipeline/data_sampling/indexed_dataset.py:211
↓ 46 callersMethodnew_group
(self, ranks)
deepspeed/comm/ccl.py:154
↓ 46 callersFunctionsee_memory_usage
(message, force=False)
deepspeed/runtime/utils.py:823
↓ 45 callersMethodsave_checkpoint
Save training checkpoint Arguments: save_dir: Required. Directory for saving the checkpoint tag: Optional. Checkpoint
deepspeed/runtime/engine.py:4859
↓ 44 callersFunctiongetCurrentCUDAStream
csrc/xpu/adam/multi_tensor_apply.dp.hpp:23
↓ 42 callersMethodfull
(self, device=None)
deepspeed/runtime/utils.py:723
↓ 41 callersMethodload
(self)
deepspeed/ops/transformer/inference/triton/matmul_ext.py:116
↓ 41 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
↓ 40 callersMethodstop
(self, **kwargs)
deepspeed/utils/timer.py:174
↓ 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
↓ 36 callersMethodcurrent_stream
(self, device_index=None)
accelerator/hpu_accelerator.py:108
↓ 35 callersFunctionallclose
(x, y, tolerances: Tuple[int, int] = None)
tests/unit/inference/v2/inference_test_utils.py:40
↓ 35 callersMethodload_checkpoint
Load training checkpoint Arguments: load_dir: Required. Directory to load the checkpoint from tag: Checkpoin
deepspeed/runtime/engine.py:4381
↓ 35 callersMethodread
(self, args, tid)
deepspeed/nvme/torch_io.py:23
↓ 34 callersMethodall_gather
(self, tensor_list, tensor, group=None, async_op=False)
deepspeed/comm/ccl.py:97
↓ 34 callersMethodcommunication_backend_name
(self)
accelerator/hpu_accelerator.py:188
↓ 34 callersMethodcurrent_device
(self)
accelerator/hpu_accelerator.py:66
↓ 34 callersMethodlog
(self, names, normalizer=1.0, reset=True, memory_breakdown=False, ranks=None)
deepspeed/utils/timer.py:192
↓ 34 callersMethodstate_dict
(self)
deepspeed/runtime/lr_schedules.py:671
↓ 33 callersMethodall_gather_into_tensor
(self, output_tensor, input_tensor, group=None, async_op=False)
deepspeed/comm/ccl.py:111
↓ 33 callersMethodfrom_pretrained
(*args, **kwargs)
deepspeed/linear/context_manager.py:68
↓ 32 callersMethodis_rocm_pytorch
()
op_builder/builder.py:206
↓ 32 callersMethodsave
(self, name: str, v: Argument, offload)
deepspeed/compile/util.py:212
↓ 32 callersMethodstep
(engine)
tests/unit/compile/test_tp_compile.py:398
↓ 31 callersMethodload
(module, state_dict, prefix)
deepspeed/inference/engine.py:346
↓ 31 callersMethodstream
(self, stream)
accelerator/hpu_accelerator.py:105
↓ 30 callersFunctionget_shard_size_list
(total_size, mp_size, name=None, num_kv_heads=None)
deepspeed/module_inject/tp_shard.py:101
↓ 29 callersMethodall_gather
(param_list=None, async_op=False, hierarchy=0)
deepspeed/runtime/zero/partition_parameters.py:1295
↓ 29 callersMethodempty_cache
(self)
accelerator/hpu_accelerator.py:120
↓ 29 callersMethodzero_grad
(self)
deepspeed/ops/lion/fused_lion.py:47
↓ 28 callersFunction_ensure_dc_ops
()
tests/unit/v1/compile/test_offload_activation.py:39
↓ 28 callersFunctionbf16_required_version_check
(accelerator_check=True)
tests/unit/util.py:39
↓ 28 callersMethodclear
(self)
deepspeed/compile/backend.py:66
↓ 28 callersMethodload
(self, name: str)
deepspeed/compile/util.py:215
↓ 28 callersMethodwrite
(self, rel: str, content: str = "")
ci/test_tests_fetcher.py:90
↓ 27 callersMethodwait
(self)
deepspeed/comm/torch.py:94
↓ 26 callersMethodadd
Track the rng state.
deepspeed/runtime/activation_checkpointing/checkpointing.py:164
↓ 26 callersMethodload
(module, state_dict, prefix, mp_group=None)
deepspeed/module_inject/auto_tp.py:159
↓ 26 callersMethodrecord
(self)
tests/unit/modeling.py:107
↓ 25 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:5816
↓ 25 callersMethodis_pinned
(self, device=None)
tests/unit/v1/compile/test_graph_profile.py:203
↓ 25 callersMethodoutput
Returns the pre-allocated, padded output Tensor.
deepspeed/inference/v2/modules/interfaces/moe_base.py:79
↓ 24 callersFunctionhasKey
csrc/includes/deepcompile.h:33
↓ 24 callersMethodsupported_dtypes
(self)
accelerator/hpu_accelerator.py:169
next →1–100 of 12,000, ranked by callers