MCPcopy Create free account

hub / github.com/deepspeedai/DeepSpeed / functions

Functions10,922 in github.com/deepspeedai/DeepSpeed

↓ 5 callersMethod_constant_buffered_norm2
(self, input, buffer_size=250000000)
deepspeed/runtime/zero/stage3.py:1760
↓ 5 callersMethod_create_config
(self, world_size, rank)
deepspeed/runtime/model_checkpointing/data_parallel_writer_factory.py:46
↓ 5 callersFunction_cutlass_moe_testing_helper
(tokens: int, in_channels: int, intermediate_d
tests/unit/inference/v2/modules/test_cutlass_moe.py:83
↓ 5 callersMethod_get_fp32_opt_state_partition
(self, param, release_swap_buffers, optim_state_key=None)
deepspeed/runtime/zero/stage3.py:2824
↓ 5 callersMethod_get_norm_groups
(self)
deepspeed/runtime/zero/stage3.py:2328
↓ 5 callersMethod_get_swap_paths
(self, params, must_exist=False)
deepspeed/runtime/swap_tensor/partitioned_param_swapper.py:148
↓ 5 callersMethod_io_aligned_numel
(self, numel)
deepspeed/runtime/swap_tensor/partitioned_param_swapper.py:386
↓ 5 callersFunction_make_internvl_adapter
(world_size=2, rank=0)
deepspeed/sequence/test_autosp.py:512
↓ 5 callersFunction_make_llava_adapter
(world_size=2, rank=0)
deepspeed/sequence/test_autosp.py:400
↓ 5 callersFunction_make_qwen2vl_adapter
(world_size=2, rank=0)
deepspeed/sequence/test_autosp.py:620
↓ 5 callersMethod_mixed_precision_dtypes
Resolve (param_dtype, buffer_dtype) for the module cast. param_dtype follows the enabled fp16/bf16 mode (None if neither). buffer_dty
deepspeed/runtime/engine.py:1405
↓ 5 callersFunction_neg
(graph, arg, name, device_time=0)
tests/unit/compile/test_list_schedule.py:110
↓ 5 callersMethod_optimizer_states_and_gradient_swap_out
(self, sub_group_id, timer_names=None)
deepspeed/runtime/zero/stage3.py:2418
↓ 5 callersMethod_partition_rank
(self, param)
deepspeed/runtime/zero/partition_parameters.py:1610
↓ 5 callersMethod_partitioned_params_swap_out
(self, i)
deepspeed/runtime/zero/stage3.py:1187
↓ 5 callersFunction_payload
()
tests/unit/v1/moe/test_autoep_autotp_dispatch.py:24
↓ 5 callersMethod_post_step
(self, timer_names)
deepspeed/runtime/zero/stage3.py:2506
↓ 5 callersFunction_ragged_embed_test_helper
Helper for embedding test to limit the number of tests to run. Params: embed_dim (int): Model dimension vocab_size (int): Le
tests/unit/inference/v2/kernels/ragged_ops/test_ragged_embed.py:48
↓ 5 callersMethod_read_autotune_table
()
deepspeed/ops/transformer/inference/triton/matmul_ext.py:455
↓ 5 callersMethod_release_params
Helper for `release_[component]` methods. Accepts a list of tuples where the first element is the module param that needs to be delet
deepspeed/module_inject/containers/features/hybrid_engine.py:100
↓ 5 callersFunction_resolve_autotp_partition
(current_param, ckpt_dict, full_hp_param, tp_rank, tp_world_size)
deepspeed/checkpoint/universal_checkpoint.py:34
↓ 5 callersFunction_router_grad_model
()
tests/unit/v1/moe/test_autoep_autotp_grad_parity.py:271
↓ 5 callersFunction_scheduled_names
(graph)
tests/unit/compile/test_list_schedule.py:124
↓ 5 callersMethod_test
(self, inputs, class_tmpdir, checkpoint_tag, mp_size, pp_size, mp_resize, pp_resize)
tests/unit/model_parallelism/test_configurable_parallel_pp.py:191
↓ 5 callersMethod_update_model_bit16_weights
(self, group_index)
deepspeed/runtime/zero/stage_1_and_2.py:774
↓ 5 callersFunction_uses_zero3_partitioned_autoep_metadata
(autoep_metadata)
deepspeed/checkpoint/ds_to_universal.py:448
↓ 5 callersFunction_zero3_functorch_config
()
tests/unit/v1/zero/test_zero_functorch_linear.py:29
↓ 5 callersFunctionadamw
r"""Functional API that performs AdamW algorithm computation. See :class:`~torch.optim.AdamW` for details.
deepspeed/ops/adam/zenflow_torch_adam.py:1044
↓ 5 callersMethodadd_export
(self, key, var)
deepspeed/launcher/multinode_runner.py:37
↓ 5 callersMethodadd_pointer_offset
Adds a pointer offset in units of Element
csrc/deepspeed4science/evoformer_attn/iterators/predicated_tile_access_iterator_residual_last.h:764
↓ 5 callersMethodbackward
(ctx, *grads)
deepspeed/runtime/sequence_parallel/ulysses_sp.py:1012
↓ 5 callersFunctionbwc_pipeline_parallel_world_size
Backwards-compatible way of querying the pipeline parallel world size.
deepspeed/utils/bwc.py:81
↓ 5 callersMethodcheck_and_propagate_first_head_layout
If all heads require same sparsity layout, it propagate first head layout to all heads Arguments: layout: required: a tensor of
deepspeed/ops/sparse_attention/sparsity_config.py:48
↓ 5 callersMethodclear
csrc/includes/deepcompile.h:235
↓ 5 callersMethodclear_mask
< Efficiently disables all accesses guarded by mask
csrc/deepspeed4science/evoformer_attn/iterators/predicated_tile_iterator_atomic.h:454
↓ 5 callersFunctioncompare_loss
(self, config, dtype, iteration=5, hidden_dim_override=None)
tests/unit/v1/compile/util.py:22
↓ 5 callersFunctioncompare_state_dicts
(state0, state1, expected_mismatch_keys=[])
tests/unit/checkpoint/common.py:88
↓ 5 callersFunctioncount_tokens_per_expert
Count routed tokens per expert. Fast path uses ``torch.bincount`` on the current device. If ``deterministic_safe=True`` and deterministic alg
deepspeed/moe/ep_count.py:12
↓ 5 callersMethodcreate
(cls, zenflow_config)
deepspeed/runtime/zenflow/zenflow_stage_1_and_2.py:82
↓ 5 callersFunctioncreate_config_from_dict
(tmpdir, config_dict)
tests/unit/simple_model.py:291
↓ 5 callersFunctiondo_aio_operation_overlap
csrc/aio/common/deepspeed_aio_common.cpp:192
↓ 5 callersFunctiondo_aio_operation_sequential
csrc/aio/common/deepspeed_aio_common.cpp:129
↓ 5 callersFunctionds_id
(param)
deepspeed/utils/debug.py:54
↓ 5 callersFunctionflatten
(d, parent_key='', sep='_')
deepspeed/autotuning/tuner/utils.py:55
↓ 5 callersMethodflops_profiler_enabled
(self)
deepspeed/runtime/engine.py:1013
↓ 5 callersMethodforward
(self, x, mask)
tests/unit/runtime/activation_checkpointing/test_activation_checkpointing.py:118
↓ 5 callersMethodfree
(self, buffers)
deepspeed/runtime/swap_tensor/utils.py:218
↓ 5 callersMethodgetDSId
csrc/includes/deepcompile.h:126
↓ 5 callersMethodgetDSTensor
csrc/includes/deepcompile.h:277
↓ 5 callersMethodget_all_ranks_from_group
(self, group)
deepspeed/comm/ccl.py:166
↓ 5 callersMethodget_bwd_mapping
(self, bw_graph: Graph)
deepspeed/compile/graph_param.py:61
↓ 5 callersMethodget_data_parallel_world_size
The number of pipelines.
deepspeed/runtime/pipe/topology.py:432
↓ 5 callersMethodget_global_rank
(self)
deepspeed/runtime/pipe/topology.py:407
↓ 5 callersMethodget_global_rank
(self, group, group_rank)
deepspeed/comm/torch.py:406
↓ 5 callersFunctionget_gpt2_model
(args_others, mp_size=1)
tests/unit/megatron_model.py:24
↓ 5 callersMethodget_gradient_for_reduction
(self, param)
deepspeed/runtime/zero/stage_1_and_2.py:1068
↓ 5 callersFunctionget_master_port
(base_port=29500, port_range_size=1000)
tests/unit/common.py:47
↓ 5 callersFunctionget_megatron_version
()
tests/unit/megatron_model.py:16
↓ 5 callersMethodget_sequence
Get the sequence descriptor for the given sequence id. If the sequence does not exist, then None is returned.
deepspeed/inference/v2/ragged/ragged_manager.py:125
↓ 5 callersMethodget_sequence_parallel_world_size
(self)
tests/unit/v1/moe/test_autoep_unit.py:283
↓ 5 callersMethodget_slice_parallel_group
(self)
deepspeed/runtime/pipe/topology.py:471
↓ 5 callersMethodget_slice_parallel_world_size
(self)
deepspeed/runtime/pipe/topology.py:465
↓ 5 callersMethodget_swap_paths
(self)
deepspeed/runtime/swap_tensor/utils.py:78
↓ 5 callersMethodget_tensor_model_parallel_world_size
(self)
tests/unit/v1/moe/test_autoep_unit.py:337
↓ 5 callersMethodgroup_step
(self, group_to_paramlist)
deepspeed/ops/adam/zenflow_torch_adam.py:197
↓ 5 callersMethodhas_all_gather_into_tensor
(self)
deepspeed/comm/torch.py:159
↓ 5 callersMethodinference_all_reduce
(self, tensor, op=ReduceOp.SUM, group=None)
deepspeed/comm/ccl.py:87
↓ 5 callersFunctioninitialize
Initialize the DeepSpeed Engine. Arguments: args: an object containing local_rank and deepspeed_config fields. This is option
deepspeed/__init__.py:93
↓ 5 callersFunctionis_autoep_zero3_partitioned_entry
(entry)
deepspeed/checkpoint/autoep_zero3_metadata.py:34
↓ 5 callersFunctionis_compiling
()
deepspeed/runtime/compiler.py:84
↓ 5 callersMethodis_first_stage
True if this process is in the first stage in the pipeline.
deepspeed/runtime/pipe/engine.py:529
↓ 5 callersMethodis_record_trace
(self)
deepspeed/runtime/zero/partitioned_param_coordinator.py:186
↓ 5 callersMethodkv_ptrs
Pointer to where the list of KV ids associated with a sequence are. If the device Tensor is requested, the Tensor is truncated to the
deepspeed/inference/v2/ragged/ragged_wrapper.py:260
↓ 5 callersFunctionload_with_byte_offset
Loads a fragment from memory
csrc/deepspeed4science/evoformer_attn/iterators/epilogue_predicated_tile_iterator.h:323
↓ 5 callersMethodload_with_pointer_offset
Loads a fragment from memory
csrc/deepspeed4science/evoformer_attn/iterators/predicated_tile_iterator_residual_last.h:812
↓ 5 callersFunctionlog_rank0
(msg: str, enable: bool = False)
deepspeed/compile/util.py:88
↓ 5 callersMethodlog_timers
(self)
deepspeed/runtime/swap_tensor/optimizer_utils.py:216
↓ 5 callersFunctionmacs_to_string
(macs, units=None, precision=DEFAULT_PRECISION)
deepspeed/profiling/flops_profiler/profiler.py:1123
↓ 5 callersFunctionmake_cutlass_checkout
(path)
tests/unit/ops/deepspeed4science/test_evoformer_attn_builder.py:16
↓ 5 callersMethodneeds_scaler
Check if this optimizer requires loss scaling for correct backward pass. Returns True if any of the following conditions are met:
deepspeed/runtime/base_optimizer.py:382
↓ 5 callersFunctionparams_to_string
(params_num, units=None, precision=DEFAULT_PRECISION)
deepspeed/profiling/flops_profiler/profiler.py:1169
↓ 5 callersMethodquantize
(self, parameter_group, overflow, eigenvalue_enabled, block_eigenvalue={})
deepspeed/runtime/quantize.py:51
↓ 5 callersFunctionreduce
(tensor, dst, op=ReduceOp.SUM, group=None, async_op=False,
deepspeed/comm/comm.py:595
↓ 5 callersMethodref
Returns a TensorRef to the operand
csrc/deepspeed4science/evoformer_attn/gemm/custom_mma_base.h:118
↓ 5 callersFunctionrequires_offset
csrc/includes/quantization.h:20
↓ 5 callersMethodrun_gpt2_test
(self, test_config, output)
tests/model/Megatron_GPT2/test_common.py:55
↓ 5 callersMethodrun_test
(self, test_config, r_tol)
tests/model/BingBertSquad/BingBertSquad_run_func_test.py:113
↓ 5 callersFunctionrun_training_steps
(engine, num_steps=3, seq_len=8, hidden_dim=64)
tests/unit/v1/moe/autoep_test_utils.py:246
↓ 5 callersMethodsave
(self, state_dict, path: str)
deepspeed/runtime/checkpoint_engine/checkpoint_engine.py:32
↓ 5 callersMethodset_dependency
Set dependency can be used for managing dependencies when a mapping is provided in the class definition for the layer. The dep_name h
deepspeed/inference/v2/model_implementations/layer_container_base.py:272
↓ 5 callersMethodset_residual_tile
csrc/deepspeed4science/evoformer_attn/iterators/predicated_tile_access_iterator_residual_last.h:760
↓ 5 callersMethodset_tensor_parallel_config
(self, mp_size, mp_group)
deepspeed/module_inject/auto_tp.py:341
↓ 5 callersFunctionshard_tensor_node
(gm: GraphModule, tensor_node: Node)
deepspeed/compile/util.py:596
↓ 5 callersFunctionsingle_all_to_all
(input, scatter_idx, gather_idx, batch_dim_idx, group, async_op=False, handle=None, type=None)
deepspeed/sequence/layer.py:241
↓ 5 callersMethodstep
Update the model parameters. .. note:: This method will be called internally by ZeRO-Offload. DeepSpeed users should
deepspeed/ops/adam/cpu_adam.py:107
↓ 5 callersMethodstep
Not supporting closure.
deepspeed/runtime/zenflow/zenflow_stage_1_and_2.py:750
↓ 5 callersMethodstore_with_pointer_offset
Store a fragment to memory
csrc/deepspeed4science/evoformer_attn/iterators/predicated_tile_iterator_residual_last.h:830
↓ 5 callersFunctiontask_log
(tid, msg, force=False)
deepspeed/nvme/test_ds_aio_utils.py:20
↓ 5 callersFunctiontask_log
(tid, msg, force=False)
csrc/aio/py_test/test_ds_aio_utils.py:20
↓ 5 callersMethodto_layers
(self)
tests/unit/alexnet_model.py:51
← previousnext →501–600 of 10,922, ranked by callers