#
Kwargs handlers

The following objects can be passed to the main Accelerator to customize how some PyTorch objects related to distributed training or mixed precision are created.

##
AutocastKwargs

###
class accelerate.AutocastKwargs

< source >

( enabled: bool = True cache_enabled: bool = None )

Use this object in your Accelerator to customize how `torch.autocast` behaves. Please refer to the documentation of this context manager for more information on each argument.

Example:

    from accelerate import Accelerator
    from accelerate.utils import AutocastKwargs

    kwargs = AutocastKwargs(cache_enabled=True)
    accelerator = Accelerator(kwargs_handlers=[kwargs])

##
DistributedDataParallelKwargs

###
class accelerate.DistributedDataParallelKwargs

< source >

( dim: int = 0 broadcast_buffers: bool = True bucket_cap_mb: int = 25 find_unused_parameters: bool = False check_reduction: bool = False gradient_as_bucket_view: bool = False static_graph: bool = False comm_hook: DDPCommunicationHookType = <DDPCommunicationHookType.NO: 'no'> comm_wrapper: typing.Literal[<DDPCommunicationHookType.NO: 'no'>, <DDPCommunicationHookType.FP16: 'fp16'>, <DDPCommunicationHookType.BF16: 'bf16'>] = <DDPCommunicationHookType.NO: 'no'> comm_state_option: dict = <factory> )

Use this object in your Accelerator to customize how your model is wrapped in a `torch.nn.parallel.DistributedDataParallel`. Please refer to the documentation of this wrapper for more information on each argument.

`gradient_as_bucket_view` is only available in PyTorch 1.7.0 and later versions.

`static_graph` is only available in PyTorch 1.11.0 and later versions.

Example:

    from accelerate import Accelerator
    from accelerate.utils import DistributedDataParallelKwargs

    kwargs = DistributedDataParallelKwargs(find_unused_parameters=True)
    accelerator = Accelerator(kwargs_handlers=[kwargs])

##
FP8RecipeKwargs

###
class accelerate.utils.FP8RecipeKwargs

< source >

( opt_level: typing.Literal['O1', 'O2'] = None use_autocast_during_eval: bool = None margin: int = None interval: int = None fp8_format: typing.Literal['HYBRID', 'E4M3', 'E5M2'] = None amax_history_len: int = None amax_compute_algo: typing.Literal['max', 'most_recent'] = None override_linear_precision: tuple = None backend: typing.Literal['MSAMP', 'TE'] = None )

Deprecated. Please use one of the proper FP8 recipe kwargs classes such as `TERecipeKwargs` or `MSAMPRecipeKwargs` instead.

##
ProfileKwargs

###
class accelerate.ProfileKwargs

< source >

( activities: typing.Optional[list[typing.Literal['cpu', 'xpu', 'mtia', 'cuda', 'hpu']]] = None schedule_option: typing.Optional[dict[str, int]] = None on_trace_ready: typing.Optional[typing.Callable] = None record_shapes: bool = False profile_memory: bool = False with_stack: bool = False with_flops: bool = False with_modules: bool = False output_trace_dir: typing.Optional[str] = None )

Parameters

- activities (`List[str]`, optional, default to `None`) — The list of activity groups to use in profiling. Must be one of `"cpu"`, `"xpu"`, `"mtia"`, “hpu” or `"cuda"`.
- schedule_option (`Dict[str, int]`, optional, default to `None`) — The schedule option to use for the profiler. Available keys are `wait`, `warmup`, `active`, `repeat` and `skip_first`. The profiler will skip the first `skip_first` steps, then wait for `wait` steps, then do the warmup for the next `warmup` steps, then do the active recording for the next `active` steps and then repeat the cycle starting with `wait` steps. The optional number of cycles is specified with the `repeat` parameter, the zero value means that the cycles will continue until the profiling is finished.
- on_trace_ready (`Callable`, optional, default to `None`) — Callable that is called at each step when schedule returns `ProfilerAction.RECORD_AND_SAVE` during the profiling.
- record_shapes (`bool`, optional, default to `False`) — Save information about operator’s input shapes.
- profile_memory (`bool`, optional, default to `False`) — Track tensor memory allocation/deallocation
- with_stack (`bool`, optional, default to `False`) — Record source information (file and line number) for the ops.
- with_flops (`bool`, optional, default to `False`) — Use formula to estimate the FLOPS of specific operators
- with_modules (`bool`, optional, default to `False`) — Record module hierarchy (including function names) corresponding to the callstack of the op.
- output_trace_dir (`str`, optional, default to `None`) — Exports the collected trace in Chrome JSON format. Chrome use ‘chrome://tracing’ view json file. Defaults to None, which means profiling does not store json files.

Use this object in your Accelerator to customize the initialization of the profiler. Please refer to the documentation of this context manager for more information on each argument.

`torch.profiler` is only available in PyTorch 1.8.1 and later versions.

Example:

    from accelerate import Accelerator
    from accelerate.utils import ProfileKwargs

    kwargs = ProfileKwargs(activities=["cpu", "cuda"])
    accelerator = Accelerator(kwargs_handlers=[kwargs])

####
build

< source >

( ) →
torch.profiler.profile

Returns

torch.profiler.profile

The profiler object.

Build a profiler object with the current configuration.

##
GradScalerKwargs

###
class accelerate.GradScalerKwargs

< source >

( init_scale: float = 65536.0 growth_factor: float = 2.0 backoff_factor: float = 0.5 growth_interval: int = 2000 enabled: bool = True )

Use this object in your Accelerator to customize the behavior of mixed precision, specifically how the `torch.amp.GradScaler` or `torch.cuda.amp.GradScaler` used is created. Please refer to the documentation of this scaler for more information on each argument.

`torch.cuda.amp.GradScaler` is only available in PyTorch 1.5.0 and later versions, and `torch.amp.GradScaler` is only available in PyTorch 2.4.0 and later versions.

Example:

    from accelerate import Accelerator
    from accelerate.utils import GradScalerKwargs

    kwargs = GradScalerKwargs(backoff_factor=0.25)
    accelerator = Accelerator(kwargs_handlers=[kwargs])

##
InitProcessGroupKwargs

###
class accelerate.InitProcessGroupKwargs

< source >

( backend: typing.Optional[str] = 'nccl' init_method: typing.Optional[str] = None timeout: typing.Optional[datetime.timedelta] = None )

Use this object in your Accelerator to customize the initialization of the distributed processes. Please refer to the documentation of this method for more information on each argument.

Note: If `timeout` is set to `None`, the default will be based upon how `backend` is set.

    from datetime import timedelta
    from accelerate import Accelerator
    from accelerate.utils import InitProcessGroupKwargs

    kwargs = InitProcessGroupKwargs(timeout=timedelta(seconds=800))
    accelerator = Accelerator(kwargs_handlers=[kwargs])

##
KwargsHandler

###
class accelerate.utils.KwargsHandler

< source >

( )

Internal mixin that implements a `to_kwargs()` method for a dataclass.

####
to_kwargs

< source >

( )

Returns a dictionary containing the attributes with values different from the default of this class.

< > Update on GitHub