Skip to content

vllm.config.fault_tolerance

Classes:

Functions:

FaultToleranceConfig

Configuration for fault tolerance.

Attributes:

Source code in vllm/config/fault_tolerance.py 
12
13
14
15
16
17
18
19
20
21
22
@config
class FaultToleranceConfig:
    """Configuration for fault tolerance."""

    engine_recovery_timeout_sec: int = 120
    """Timeout (in seconds) to wait for error handling instructions
    before raising an exception. If the EngineCore encounters an
    error, it waits up to this many seconds for vLLM to receive
    instructions on how to handle the error and then recover from the fault.
    If vLLM does not recover during this time, the original error is raised.
    """

engine_recovery_timeout_sec = 120 class-attribute instance-attribute

Timeout (in seconds) to wait for error handling instructions before raising an exception. If the EngineCore encounters an error, it waits up to this many seconds for vLLM to receive instructions on how to handle the error and then recover from the fault. If vLLM does not recover during this time, the original error is raised.

ft_tp_barrier_required(parallel_config)

Whether the per-step FT barrier over the TP cpu group is armed.

The barrier makes TP peers fail on the host within the gloo timeout instead of leaving an orphaned TP collective on the device stream.

Source code in vllm/config/fault_tolerance.py 
25
26
27
28
29
30
31
32
33
34
def ft_tp_barrier_required(parallel_config: "ParallelConfig") -> bool:
    """Whether the per-step FT barrier over the TP cpu group is armed.

    The barrier makes TP peers fail on the host within the gloo timeout
    instead of leaving an orphaned TP collective on the device stream.
    """
    return (
        parallel_config.enable_fault_tolerance
        and parallel_config.tensor_parallel_size > 1
    )