MCPcopy Create free account

hub / github.com/deepspeedai/DeepSpeed / functions

Functions11,258 in github.com/deepspeedai/DeepSpeed

↓ 3 callersFunctionset_autotp_mode
Set the DEEPSPEED_AUTOTP_MODE based on the training flag
deepspeed/module_inject/layers.py:117
↓ 3 callersMethodset_checkpoint_interval
(self, interval)
deepspeed/runtime/pipe/module.py:555
↓ 3 callersMethodset_dataiterator
Store an iterator to sample for training data.
deepspeed/runtime/pipe/engine.py:668
↓ 3 callersMethodset_module
(self, sd, module)
deepspeed/runtime/state_dict_factory.py:157
↓ 3 callersFunctionset_z3_leaf_modules_by_name
Sets a leaf flag for modules referenced by their names in ``model.named_modules()``. Args: model (torch.nn.Module): The model cont
deepspeed/utils/z3_leaf_module.py:89
↓ 3 callersFunctionset_z3_leaf_modules_by_suffix
Sets a leaf flag for modules referenced by suffixes of ``model.named_modules()`` names.
deepspeed/utils/z3_leaf_module.py:120
↓ 3 callersFunctionshould_log_le
Args: max_log_level_str: maximum log level as a string Returns ``True`` if the current log_level is less or equal to the specified l
deepspeed/utils/logging.py:215
↓ 3 callersMethodshould_refresh_expected_hook_count
Return True when count_used_parameters_in_backward() should be re-evaluated.
deepspeed/runtime/base_optimizer.py:451
↓ 3 callersMethodskip_autotune
(self)
deepspeed/ops/transformer/inference/triton/matmul_ext.py:224
↓ 3 callersFunctionskip_on_device
()
tests/unit/model_parallelism/test_tp_plan_e2e.py:18
↓ 3 callersFunctionskip_on_device
()
tests/unit/model_parallelism/test_tp_plan_real_models.py:17
↓ 3 callersFunctionsort_dtypes
(dtypes: List[torch.dtype])
deepspeed/runtime/torch_autocast.py:89
↓ 3 callersMethodstart_profile
Starts profiling. Extra attributes are added recursively to all the modules and the profiled torch.nn.functionals are monkey patched.
deepspeed/profiling/flops_profiler/profiler.py:74
↓ 3 callersMethodstep
Update the model parameters. .. note:: This method will be called internally by ZeRO-Offload. DeepSpeed users should
deepspeed/ops/adagrad/cpu_adagrad.py:37
↓ 3 callersMethodstep
(self)
deepspeed/runtime/quantize.py:75
↓ 3 callersMethodstore_with_byte_offset
Store a fragment to memory
csrc/deepspeed4science/evoformer_attn/iterators/predicated_tile_iterator_residual_last.h:837
↓ 3 callersMethodsynchronize_reads
(self)
deepspeed/runtime/swap_tensor/partitioned_param_swapper.py:213
↓ 3 callersMethodto_meta
Returns a torch.LongTensor that encodes partitioning information. Can be used along with ``data()`` to serialize a ``PartitionedTensor`` for
deepspeed/runtime/utils.py:734
↓ 3 callersFunctiontorch_assert_equal
Compare two tensors or non-tensor numbers for their equality. Add msg=blah to add an additional comment to when assert fails.
tests/unit/util.py:129
↓ 3 callersMethodtp_parser
(model)
deepspeed/module_inject/auto_tp.py:291
↓ 3 callersMethodtrain
r
deepspeed/runtime/engine.py:2619
↓ 3 callersMethodtransform_gate_param
Perform any necessary transformations of the gate parameter. Args: param (torch.Tensor): gate_w (shape: [num_experts, mo
deepspeed/inference/v2/modules/interfaces/moe_base.py:35
↓ 3 callersMethodtransform_mlp_1_param
Shards the first MLP parameter and passes it to the underlying implementation for any necessary transformations. Args:
deepspeed/inference/v2/model_implementations/inference_transformer_base.py:454
↓ 3 callersMethodunpack
(self, buffer, size, dtype)
deepspeed/runtime/comm/compressed.py:53
↓ 3 callersFunctionunpatch_compiled_func
Restore torch.autograd.Function and discard inputs captured for this compile cycle.
deepspeed/compile/patch_compiled_func.py:94
↓ 3 callersMethodunregisterGatheredParam
csrc/includes/deepcompile.h:423
↓ 3 callersMethodunscale_and_clip_grads
(self, sub_group_id, total_norm)
deepspeed/runtime/zero/stage3.py:2642
↓ 3 callersFunctionunsupported_preset_for_hf_model_type
Return a preset carrying an actionable diagnostic for an unsupported HF model_type.
deepspeed/module_inject/auto_ep_presets/registry.py:92
↓ 3 callersMethodupdate
( self, key_states: torch.Tensor, value_states: torch.Tensor, *args, *
deepspeed/utils/static_cache.py:77
↓ 3 callersMethodupdate_hook_state_and_maybe_run_epilogue
Update hook state after a gradient hook fires and run epilogue if all hooks have fired.
deepspeed/runtime/base_optimizer.py:459
↓ 3 callersMethodupdate_records
(self, space_name, exp, metric_val, num_exps)
deepspeed/autotuning/autotuner.py:708
↓ 3 callersMethoduse_node_local_storage
(self)
deepspeed/runtime/engine.py:1340
↓ 3 callersMethodvalidate_args
(self)
deepspeed/launcher/multinode_runner.py:274
↓ 3 callersMethodvisible_devices_envs
(self)
accelerator/hpu_accelerator.py:308
↓ 3 callersFunctionwarning_once
This method is identical to `logger.warning()`, but will emit the warning with the same message only once Note: The cache is for the functio
deepspeed/utils/logging.py:65
↓ 3 callersMethodwas_step_applied
Returns True if the latest ``step()`` produced in parameter updates. Note that a ``False`` return is not an error condition. Steps are frequen
deepspeed/runtime/engine.py:2549
↓ 3 callersFunctionwrapFunc
(func, funcFlopCompute)
deepspeed/profiling/flops_profiler/profiler.py:875
↓ 3 callersFunctionwrapper
(*args, **kwargs)
deepspeed/runtime/compiler.py:68
↓ 3 callersFunctionwrapper
( w1: torch.Tensor, w2: torch.Tensor, w3: torch.Tensor, x: torch.Tensor,
deepspeed/moe/ep_kernels.py:310
↓ 3 callersMethodzenflow_cpu_optimizer_step
(self, now_state, scaled_global_grad_norm)
deepspeed/runtime/zenflow/zenflow_stage_1_and_2.py:729
↓ 3 callersFunctionzero3_post_init_quantization_test_helper
(cpu_offload: bool, nvme_offload: bool, bits: int, nvme_path=None)
tests/unit/inference/quantization/test_intX_quantization.py:57
↓ 3 callersFunctionzero3_quantized_initialization_test_helper
(cpu_offload: bool, nvme_offload: bool, bits: int, nvme_path=None)
tests/unit/inference/quantization/test_intX_quantization.py:177
↓ 3 callersMethodzero_grad
Zero FP16 parameter grads.
deepspeed/runtime/zero/stage3.py:2144
↓ 3 callersMethodzero_nvme_offload_optimizer
(self)
deepspeed/runtime/engine.py:1252
↓ 3 callersMethodzero_overlap_comm
(self)
deepspeed/runtime/engine.py:1176
↓ 2 callersMethodConfig
csrc/includes/gelu.h:18
↓ 2 callersFunctionCreateLossScaler
(dtype, static_loss_scale, dynamic_scaling, dynamic_loss_args)
deepspeed/runtime/fp16/loss_scaler.py:305
↓ 2 callersFunctionDS4Sci_EvoformerAttention
(Q, K, V, biases)
deepspeed/ops/deepspeed4science/evoformer_attn.py:88
↓ 2 callersMethodForward
csrc/transformer/ds_transformer_cuda.cpp:154
↓ 2 callersMethodForwardWithBiasAdd
csrc/includes/gelu.h:25
↓ 2 callersMethodGeluCheckpoint
csrc/includes/ds_transformer_cuda.h:145
↓ 2 callersMethodGetHiddenSize
csrc/includes/ds_transformer_cuda.h:142
↓ 2 callersMethodGetIntermediateSize
csrc/includes/ds_transformer_cuda.h:139
↓ 2 callersMethodGetNumHeads
csrc/includes/softmax.h:57
↓ 2 callersMethodGetSeqLength
csrc/includes/softmax.h:59
↓ 2 callersMethodGetTimeInSeconds
csrc/includes/StopWatch.h:45
↓ 2 callersMethodIsTrainingMode
csrc/includes/ds_transformer_cuda.h:144
↓ 2 callersMethodRestart
csrc/includes/StopWatch.h:29
↓ 2 callersMethodSetIntermediateBuffers
csrc/transformer/ds_transformer_cuda.cpp:566
↓ 2 callersMethodSetSeqLength
csrc/transformer/ds_transformer_cuda.cpp:585
↓ 2 callersMethodSetWorkSpace
csrc/includes/context.h:76
↓ 2 callersMethodSoftmax
csrc/includes/softmax.h:38
↓ 2 callersMethodStop
csrc/includes/StopWatch.h:35
↓ 2 callersMethodUseMean
csrc/includes/normalize_layer.h:188
↓ 2 callersFunction_Wait_bwd_comm
(input_, dic_, h_id)
deepspeed/runtime/domino/transformer.py:50
↓ 2 callersMethod__getattr__
Pass through attributes defined in the model if they are not overridden by ds-engine.
deepspeed/runtime/engine.py:927
↓ 2 callersMethod__getstate__
(self)
deepspeed/linear/quantization.py:85
↓ 2 callersMethod__init__
(self, out=True, err=True, replay=True)
tests/unit/util.py:230
↓ 2 callersMethod__init__
(self, attn: nn.Module)
tests/unit/sequence_parallelism/test_autosp_integration.py:89
↓ 2 callersMethod__init__
(self, result: str)
tests/unit/inference/v2/model_implementations/test_exaone4_5.py:101
↓ 2 callersMethod__init__
(self, tp_world_size=1)
tests/unit/model_parallelism/test_autotp_training.py:97
↓ 2 callersMethod__init__
(self, batch_size, hidden_size, intermediate_size, heads, attn_dropout_ratio, hidden_dropout_ratio,
deepspeed/ops/transformer/transformer.py:21
↓ 2 callersMethod__init__
(self, config, q_scales=None, q_groups=1, merge_count=1, mlp_extra_grouping=False, mp_group=None)
deepspeed/ops/transformer/inference/moe_inference.py:133
↓ 2 callersMethod__init__
(self, chunk: torch.Tensor, device=None, is_in_use=False)
deepspeed/sequence/fpdt_layer.py:499
↓ 2 callersMethod__init__
A context manager to partition the model parameters during the model construction with MiCS partition strategy. Model states are partitioned
deepspeed/runtime/zero/mics.py:65
↓ 2 callersMethod__init__
Create a mapping of n-dimensional tensor coordinates to linear indices. Arguments: axes (list): the names of the tensor axes
deepspeed/runtime/pipe/topology.py:26
↓ 2 callersMethod__init__
(self, typename, *module_args, **module_kwargs)
deepspeed/runtime/pipe/module.py:53
↓ 2 callersMethod__init__
(self, path)
deepspeed/runtime/data_pipeline/data_sampling/indexed_dataset.py:143
↓ 2 callersMethod__init__
( self, init_optimizer, param_names, timers, optimizer_params,
deepspeed/runtime/zenflow/zenflow_stage_1_and_2.py:49
↓ 2 callersMethod__init__
(self, scale=1)
deepspeed/runtime/fp16/loss_scaler.py:175
↓ 2 callersMethod__init__
(self, vocab_size, hidden_size, num_layers, num_heads, max_seq_len, dropout=0.1)
examples/sdma_allgather/train_zero3.py:82
↓ 2 callersMethod__init__
(self, attn_cls, hidden: int)
benchmarks/autosp/bench_multimodal_sp.py:90
↓ 2 callersMethod__new__
( cls, data: Optional[torch.Tensor] = None, requires_grad: bool = False, # quantized
deepspeed/linear/quantization.py:37
↓ 2 callersMethod__reduce_and_partition_ipg_grads
(self, communication_data_type: torch.dtype)
deepspeed/runtime/zero/stage3.py:1494
↓ 2 callersMethod__setstate__
(self, state)
deepspeed/linear/quantization.py:92
↓ 2 callersMethod_add_tensors
(self, tensor_list)
deepspeed/runtime/swap_tensor/optimizer_utils.py:66
↓ 2 callersFunction_all_real_if_tensor
(args)
deepspeed/compile/profilers/graph_profile.py:26
↓ 2 callersMethod_all_source_files
(self)
ci/tests_fetcher.py:271
↓ 2 callersMethod_all_test_files
(self)
ci/tests_fetcher.py:263
↓ 2 callersFunction_alloc_reload_buffer
(like_tensor, compute_stream)
deepspeed/compile/passes/offload_adam_states.py:91
↓ 2 callersMethod_allocate_and_return_buffers_for_swap_in
(self, params)
deepspeed/runtime/swap_tensor/partitioned_param_swapper.py:178
↓ 2 callersMethod_allocate_or_extend_buffers
(self, idx, shape, dtype)
deepspeed/runtime/pipe/engine.py:1307
↓ 2 callersFunction_assert_grad_maps_close
(actual, expected, *, lhs_name, rhs_name)
tests/unit/v1/moe/test_autoep_grad_parity.py:140
↓ 2 callersFunction_assert_module_params_match_universal
(engine, universal_dir)
tests/unit/v1/moe/test_autoep_checkpoint.py:271
↓ 2 callersFunction_assert_same_dtype_device
(actual, expected)
tests/unit/v1/moe/test_autoep_unit.py:99
↓ 2 callersMethod_assert_sparse_routes_match
(combine_weights, sparse_output)
tests/unit/v1/moe/test_moe.py:305
↓ 2 callersMethod_assert_zero3_universal_weights_only_load
(self, tmpdir, load_kwargs)
tests/unit/v1/moe/test_autoep_checkpoint.py:478
↓ 2 callersMethod_assign_resources_to_tensor_slice
(self, slice_resources, my_slice_index, my_dp_ranks)
deepspeed/runtime/model_checkpointing/data_parallel_writer_factory.py:178
↓ 2 callersFunction_autoep_expert_param_names_by_rank
(model_files)
deepspeed/checkpoint/ds_to_universal.py:535
↓ 2 callersMethod_autoep_expert_parameter_names
(autoep_layers, model)
deepspeed/runtime/engine.py:4330
← previousnext →1,201–1,300 of 11,258, ranked by callers