59a0a3844c
PR Test AMD / cancel-on-close (push) Has been skipped
PR Test NVIDIA ARM / scan (push) Has been skipped
PR Test NVIDIA / cancel-on-close (push) Has been skipped
PR Test AMD / scan (push) Has been skipped
PR Test NVIDIA ARM / cancel-on-close (push) Has been skipped
PR Test NVIDIA / scan (push) Has been skipped
Release Docker Images / build (cu129-torch-2.11.0) (push) Has been skipped
Release Docker Images / build (cu130-torch-2.11.0) (push) Has been skipped
Release PyPI / publish (push) Has been skipped
Scheduler Python Test / test (push) Successful in 27m19s
Docs / build (push) Successful in 28m8s
Scheduler C++ Test / test (push) Successful in 28m19s
Scheduler C++ Test / test-flat (push) Successful in 28m18s
Docs / deploy (push) Has been cancelled
PR Test AMD / finish (push) Has been cancelled
PR Test NVIDIA / finish (push) Has been cancelled
PR Test NVIDIA ARM / finish (push) Has been cancelled
PR Test NVIDIA ARM / ${{ matrix.name }} (${{ matrix.runner }}) (push) Has been cancelled
PR Test AMD / ${{ matrix.name }} (${{ matrix.runner }}) (push) Has been cancelled
PR Test NVIDIA / ${{ matrix.name }} (${{ matrix.runner }}) (push) Has been cancelled
810 lines
31 KiB
Python
Executable File
810 lines
31 KiB
Python
Executable File
# Copyright (c) 2026 LightSeek Foundation
|
|
#
|
|
# Permission is hereby granted, free of charge, to any person obtaining a copy
|
|
# of this software and associated documentation files (the "Software"), to deal
|
|
# in the Software without restriction, including without limitation the rights
|
|
# to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
|
|
# copies of the Software, and to permit persons to whom the Software is
|
|
# furnished to do so, subject to the following conditions:
|
|
#
|
|
# The above copyright notice and this permission notice shall be included in
|
|
# all copies or substantial portions of the Software.
|
|
#
|
|
# THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
|
|
# IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
|
|
# FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
|
|
# AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
|
|
# LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
|
|
# OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
|
|
# SOFTWARE.
|
|
|
|
"""Shared configuration utilities."""
|
|
|
|
import math
|
|
|
|
from transformers.configuration_utils import PretrainedConfig
|
|
from transformers.utils import is_torch_available, logging
|
|
|
|
logger = logging.get_logger(__name__)
|
|
|
|
|
|
if is_torch_available():
|
|
import torch
|
|
|
|
|
|
def get_rope_theta(config, default: float = 10000.0) -> float:
|
|
"""Return rope_theta from config, including the transformers 5.x fallback."""
|
|
theta = getattr(config, "rope_theta", None)
|
|
if theta is not None:
|
|
return theta
|
|
rope_scaling = getattr(config, "rope_scaling", None)
|
|
if isinstance(rope_scaling, dict):
|
|
return rope_scaling.get("rope_theta", default)
|
|
return default
|
|
|
|
|
|
def get_rope_parameters(config):
|
|
"""Return TokenSpeed's full RoPE config, including private extensions."""
|
|
return (
|
|
getattr(config, "_tokenspeed_rope_parameters", None)
|
|
or getattr(config, "rope_parameters", None)
|
|
or {}
|
|
)
|
|
|
|
|
|
def _compute_default_rope_parameters(
|
|
config: PretrainedConfig | None = None,
|
|
device: "torch.device | None" = None,
|
|
seq_len: int | None = None,
|
|
**rope_kwargs,
|
|
) -> tuple["torch.Tensor", float]:
|
|
"""
|
|
Computes the inverse frequencies according to the original RoPE implementation
|
|
Args:
|
|
config ([`~transformers.PretrainedConfig`]):
|
|
The model configuration.
|
|
device (`torch.device`):
|
|
The device to use for initialization of the inverse frequencies.
|
|
seq_len (`int`, *optional*):
|
|
The current sequence length. Unused for this type of RoPE.
|
|
rope_kwargs (`Dict`, *optional*):
|
|
BC compatibility with the previous RoPE class instantiation, will be removed in v4.45.
|
|
Returns:
|
|
Tuple of (`torch.Tensor`, `float`), containing the inverse frequencies for the RoPE embeddings and the
|
|
post-processing scaling factor applied to the computed cos/sin (unused in this type of RoPE).
|
|
"""
|
|
if config is not None and rope_kwargs:
|
|
raise ValueError(
|
|
"Unexpected arguments: `**rope_kwargs` and `config` are mutually exclusive in "
|
|
f"`_compute_default_rope_parameters`, got `rope_kwargs`={rope_kwargs} and `config`={config}"
|
|
)
|
|
if rope_kwargs:
|
|
base = rope_kwargs["base"]
|
|
dim = rope_kwargs["dim"]
|
|
elif config is not None:
|
|
base = config.rope_theta
|
|
partial_rotary_factor = (
|
|
config.partial_rotary_factor
|
|
if hasattr(config, "partial_rotary_factor")
|
|
else 1.0
|
|
)
|
|
head_dim = getattr(
|
|
config, "head_dim", config.hidden_size // config.num_attention_heads
|
|
)
|
|
dim = int(head_dim * partial_rotary_factor)
|
|
|
|
attention_factor = 1.0 # Unused in this type of RoPE
|
|
|
|
# Compute the inverse frequencies
|
|
inv_freq = 1.0 / (
|
|
base
|
|
** (
|
|
torch.arange(0, dim, 2, dtype=torch.int64).to(
|
|
device=device, dtype=torch.float
|
|
)
|
|
/ dim
|
|
)
|
|
)
|
|
return inv_freq, attention_factor
|
|
|
|
|
|
def _compute_linear_scaling_rope_parameters(
|
|
config: PretrainedConfig | None = None,
|
|
device: "torch.device | None" = None,
|
|
seq_len: int | None = None,
|
|
**rope_kwargs,
|
|
) -> tuple["torch.Tensor", float]:
|
|
"""
|
|
Computes the inverse frequencies with linear scaling. Credits to the Reddit user /u/kaiokendev
|
|
Args:
|
|
config ([`~transformers.PretrainedConfig`]):
|
|
The model configuration.
|
|
device (`torch.device`):
|
|
The device to use for initialization of the inverse frequencies.
|
|
seq_len (`int`, *optional*):
|
|
The current sequence length. Unused for this type of RoPE.
|
|
rope_kwargs (`Dict`, *optional*):
|
|
BC compatibility with the previous RoPE class instantiation, will be removed in v4.45.
|
|
Returns:
|
|
Tuple of (`torch.Tensor`, `float`), containing the inverse frequencies for the RoPE embeddings and the
|
|
post-processing scaling factor applied to the computed cos/sin (unused in this type of RoPE).
|
|
"""
|
|
if config is not None and rope_kwargs:
|
|
raise ValueError(
|
|
"Unexpected arguments: `**rope_kwargs` and `config` are mutually exclusive in "
|
|
f"`_compute_linear_scaling_rope_parameters`, got `rope_kwargs`={rope_kwargs} and `config`={config}"
|
|
)
|
|
if rope_kwargs:
|
|
factor = rope_kwargs["factor"]
|
|
elif config is not None:
|
|
factor = config.rope_scaling["factor"]
|
|
|
|
# Gets the default RoPE parameters
|
|
inv_freq, attention_factor = _compute_default_rope_parameters(
|
|
config, device, seq_len, **rope_kwargs
|
|
)
|
|
|
|
# Then applies linear scaling to the frequencies.
|
|
# originally, scaling was applied to the position_ids. However, we get `embs = inv_freq @ position_ids`, so
|
|
# applying scaling to the inverse frequencies is equivalent.
|
|
inv_freq /= factor
|
|
return inv_freq, attention_factor
|
|
|
|
|
|
def _compute_dynamic_ntk_parameters(
|
|
config: PretrainedConfig | None = None,
|
|
device: "torch.device | None" = None,
|
|
seq_len: int | None = None,
|
|
**rope_kwargs,
|
|
) -> tuple["torch.Tensor", float]:
|
|
"""
|
|
Computes the inverse frequencies with NTK scaling. Credits to the Reddit users /u/bloc97 and /u/emozilla
|
|
Args:
|
|
config ([`~transformers.PretrainedConfig`]):
|
|
The model configuration.
|
|
device (`torch.device`):
|
|
The device to use for initialization of the inverse frequencies.
|
|
seq_len (`int`, *optional*):
|
|
The current sequence length, used to update the dynamic RoPE at inference time.
|
|
rope_kwargs (`Dict`, *optional*):
|
|
BC compatibility with the previous RoPE class instantiation, will be removed in v4.45.
|
|
Returns:
|
|
Tuple of (`torch.Tensor`, `float`), containing the inverse frequencies for the RoPE embeddings and the
|
|
post-processing scaling factor applied to the computed cos/sin (unused in this type of RoPE).
|
|
"""
|
|
if config is not None and rope_kwargs:
|
|
raise ValueError(
|
|
"Unexpected arguments: `**rope_kwargs` and `config` are mutually exclusive in "
|
|
f"`_compute_dynamic_ntk_parameters`, got `rope_kwargs`={rope_kwargs} and `config`={config}"
|
|
)
|
|
if rope_kwargs:
|
|
base = rope_kwargs["base"]
|
|
dim = rope_kwargs["dim"]
|
|
max_position_embeddings = rope_kwargs["max_position_embeddings"]
|
|
factor = rope_kwargs["factor"]
|
|
elif config is not None:
|
|
base = config.rope_theta
|
|
partial_rotary_factor = (
|
|
config.partial_rotary_factor
|
|
if hasattr(config, "partial_rotary_factor")
|
|
else 1.0
|
|
)
|
|
head_dim = getattr(
|
|
config, "head_dim", config.hidden_size // config.num_attention_heads
|
|
)
|
|
dim = int(head_dim * partial_rotary_factor)
|
|
max_position_embeddings = config.max_position_embeddings
|
|
factor = config.rope_scaling["factor"]
|
|
|
|
attention_factor = 1.0 # Unused in this type of RoPE
|
|
|
|
# seq_len: default to max_position_embeddings, e.g. at init time
|
|
seq_len = (
|
|
seq_len
|
|
if seq_len is not None and seq_len > max_position_embeddings
|
|
else max_position_embeddings
|
|
)
|
|
|
|
# Compute the inverse frequencies
|
|
base = base * ((factor * seq_len / max_position_embeddings) - (factor - 1)) ** (
|
|
dim / (dim - 2)
|
|
)
|
|
inv_freq = 1.0 / (
|
|
base
|
|
** (
|
|
torch.arange(0, dim, 2, dtype=torch.int64).to(
|
|
device=device, dtype=torch.float
|
|
)
|
|
/ dim
|
|
)
|
|
)
|
|
return inv_freq, attention_factor
|
|
|
|
|
|
def _compute_yarn_parameters(
|
|
config: PretrainedConfig,
|
|
device: "torch.device",
|
|
seq_len: int | None = None,
|
|
**rope_kwargs,
|
|
) -> tuple["torch.Tensor", float]:
|
|
"""
|
|
Computes the inverse frequencies with NTK scaling. Please refer to the
|
|
[original paper](https://arxiv.org/abs/2309.00071)
|
|
Args:
|
|
config ([`~transformers.PretrainedConfig`]):
|
|
The model configuration.
|
|
device (`torch.device`):
|
|
The device to use for initialization of the inverse frequencies.
|
|
seq_len (`int`, *optional*):
|
|
The current sequence length. Unused for this type of RoPE.
|
|
rope_kwargs (`Dict`, *optional*):
|
|
BC compatibility with the previous RoPE class instantiation, will be removed in v4.45.
|
|
Returns:
|
|
Tuple of (`torch.Tensor`, `float`), containing the inverse frequencies for the RoPE embeddings and the
|
|
post-processing scaling factor applied to the computed cos/sin.
|
|
"""
|
|
# No need to keep BC with yarn, unreleased when this new pattern was created.
|
|
if rope_kwargs:
|
|
raise ValueError(
|
|
f"Unexpected arguments: `**rope_kwargs` should be unset in `_compute_yarn_parameters`, got {rope_kwargs}"
|
|
)
|
|
|
|
base = config.rope_theta
|
|
partial_rotary_factor = (
|
|
config.partial_rotary_factor
|
|
if hasattr(config, "partial_rotary_factor")
|
|
else 1.0
|
|
)
|
|
head_dim = getattr(
|
|
config, "head_dim", config.hidden_size // config.num_attention_heads
|
|
)
|
|
dim = int(head_dim * partial_rotary_factor)
|
|
factor = config.rope_scaling["factor"]
|
|
attention_factor = config.rope_scaling.get("attention_factor")
|
|
mscale = config.rope_scaling.get("mscale")
|
|
mscale_all_dim = config.rope_scaling.get("mscale_all_dim")
|
|
|
|
# DeekSeek-V3 (and potentially other models) modify `max_position_embeddings` and have a
|
|
# `original_max_position_embeddings` field containing the pretrained value. They use the ratio between these two
|
|
# values to compute the default attention scaling factor, instead of using `factor`.
|
|
if "original_max_position_embeddings" in config.rope_scaling:
|
|
original_max_position_embeddings = config.rope_scaling[
|
|
"original_max_position_embeddings"
|
|
]
|
|
factor = config.max_position_embeddings / original_max_position_embeddings
|
|
else:
|
|
original_max_position_embeddings = config.max_position_embeddings
|
|
|
|
def get_mscale(scale, mscale=1):
|
|
if scale <= 1:
|
|
return 1.0
|
|
return 0.1 * mscale * math.log(scale) + 1.0
|
|
|
|
# Sets the attention factor as suggested in the paper
|
|
if attention_factor is None:
|
|
if mscale and mscale_all_dim:
|
|
attention_factor = float(
|
|
get_mscale(factor, mscale) / get_mscale(factor, mscale_all_dim)
|
|
)
|
|
else:
|
|
attention_factor = get_mscale(factor)
|
|
|
|
# Optional config options
|
|
# beta_fast/beta_slow: as suggested in the paper, default to 32/1 (correspondingly)
|
|
beta_fast = config.rope_scaling.get("beta_fast") or 32
|
|
beta_slow = config.rope_scaling.get("beta_slow") or 1
|
|
|
|
# Compute the inverse frequencies
|
|
def find_correction_dim(num_rotations, dim, base, max_position_embeddings):
|
|
"""Inverse dimension formula to find the dimension based on the number of rotations"""
|
|
return (
|
|
dim * math.log(max_position_embeddings / (num_rotations * 2 * math.pi))
|
|
) / (2 * math.log(base))
|
|
|
|
def find_correction_range(low_rot, high_rot, dim, base, max_position_embeddings):
|
|
"""Find dimension range bounds based on rotations"""
|
|
low = math.floor(
|
|
find_correction_dim(low_rot, dim, base, max_position_embeddings)
|
|
)
|
|
high = math.ceil(
|
|
find_correction_dim(high_rot, dim, base, max_position_embeddings)
|
|
)
|
|
return max(low, 0), min(high, dim - 1)
|
|
|
|
def linear_ramp_factor(min, max, dim):
|
|
if min == max:
|
|
max += 0.001 # Prevent singularity
|
|
|
|
linear_func = (torch.arange(dim, dtype=torch.float32) - min) / (max - min)
|
|
ramp_func = torch.clamp(linear_func, 0, 1)
|
|
return ramp_func
|
|
|
|
# Note on variable naming: "interpolation" comes from the original technique, where we interpolate the position IDs
|
|
# to expand the possible context length. In other words, interpolation = apply scaling factor.
|
|
pos_freqs = base ** (
|
|
torch.arange(0, dim, 2).to(device=device, dtype=torch.float) / dim
|
|
)
|
|
inv_freq_extrapolation = 1.0 / pos_freqs
|
|
inv_freq_interpolation = 1.0 / (factor * pos_freqs)
|
|
|
|
low, high = find_correction_range(
|
|
beta_fast, beta_slow, dim, base, original_max_position_embeddings
|
|
)
|
|
|
|
# Get n-dimensional rotational scaling corrected for extrapolation
|
|
inv_freq_extrapolation_factor = 1 - linear_ramp_factor(low, high, dim // 2).to(
|
|
device=device, dtype=torch.float
|
|
)
|
|
inv_freq = (
|
|
inv_freq_interpolation * (1 - inv_freq_extrapolation_factor)
|
|
+ inv_freq_extrapolation * inv_freq_extrapolation_factor
|
|
)
|
|
return inv_freq, attention_factor
|
|
|
|
|
|
def _compute_longrope_parameters(
|
|
config: PretrainedConfig,
|
|
device: "torch.device",
|
|
seq_len: int | None = None,
|
|
**rope_kwargs,
|
|
) -> tuple["torch.Tensor", float]:
|
|
"""
|
|
Computes the inverse frequencies with LongRoPE scaling. Please refer to the
|
|
[original implementation](https://github.com/microsoft/LongRoPE)
|
|
Args:
|
|
config ([`~transformers.PretrainedConfig`]):
|
|
The model configuration.
|
|
device (`torch.device`):
|
|
The device to use for initialization of the inverse frequencies.
|
|
seq_len (`int`, *optional*):
|
|
The current sequence length.
|
|
rope_kwargs (`Dict`, *optional*):
|
|
BC compatibility with the previous RoPE class instantiation, will be removed in v4.45.
|
|
Returns:
|
|
Tuple of (`torch.Tensor`, `float`), containing the inverse frequencies for the RoPE embeddings and the
|
|
post-processing scaling factor applied to the computed cos/sin.
|
|
"""
|
|
# No need to keep BC with longrope, unreleased when this new pattern was created.
|
|
if rope_kwargs:
|
|
raise ValueError(
|
|
"Unexpected arguments: `**rope_kwargs` should be unset in `_compute_longrope_parameters`, got "
|
|
f"{rope_kwargs}"
|
|
)
|
|
|
|
base = config.rope_theta
|
|
partial_rotary_factor = (
|
|
config.partial_rotary_factor
|
|
if hasattr(config, "partial_rotary_factor")
|
|
else 1.0
|
|
)
|
|
head_dim = getattr(
|
|
config, "head_dim", config.hidden_size // config.num_attention_heads
|
|
)
|
|
dim = int(head_dim * partial_rotary_factor)
|
|
long_factor = config.rope_scaling["long_factor"]
|
|
short_factor = config.rope_scaling["short_factor"]
|
|
factor = config.rope_scaling.get("factor")
|
|
attention_factor = config.rope_scaling.get("attention_factor")
|
|
|
|
# Phi3 (and potentially other models) modify `max_position_embeddings` and have a
|
|
# `original_max_position_embeddings` field containing the pretrained value. They use the ratio between these two
|
|
# values to compute the default attention scaling factor, instead of using `factor`.
|
|
if hasattr(config, "original_max_position_embeddings"):
|
|
original_max_position_embeddings = config.original_max_position_embeddings
|
|
factor = (
|
|
config.max_position_embeddings / config.original_max_position_embeddings
|
|
)
|
|
else:
|
|
original_max_position_embeddings = config.max_position_embeddings
|
|
|
|
# Sets the attention factor as suggested in the paper
|
|
if attention_factor is None:
|
|
if factor <= 1.0:
|
|
attention_factor = 1.0
|
|
else:
|
|
attention_factor = math.sqrt(
|
|
1 + math.log(factor) / math.log(original_max_position_embeddings)
|
|
)
|
|
|
|
# Compute the inverse frequencies -- scaled based on the target sequence length
|
|
if seq_len and seq_len > original_max_position_embeddings:
|
|
ext_factors = torch.tensor(long_factor, dtype=torch.float32, device=device)
|
|
else:
|
|
ext_factors = torch.tensor(short_factor, dtype=torch.float32, device=device)
|
|
inv_freq_shape = (
|
|
torch.arange(0, dim, 2, dtype=torch.int64, device=device).float() / dim
|
|
)
|
|
inv_freq = 1.0 / (ext_factors * base**inv_freq_shape)
|
|
|
|
return inv_freq, attention_factor
|
|
|
|
|
|
def _compute_llama3_parameters(
|
|
config: PretrainedConfig,
|
|
device: "torch.device",
|
|
seq_len: int | None = None,
|
|
**rope_kwargs,
|
|
) -> tuple["torch.Tensor", float]:
|
|
"""
|
|
Computes the inverse frequencies for llama 3.1.
|
|
|
|
Args:
|
|
config ([`~transformers.PretrainedConfig`]):
|
|
The model configuration.
|
|
device (`torch.device`):
|
|
The device to use for initialization of the inverse frequencies.
|
|
seq_len (`int`, *optional*):
|
|
The current sequence length. Unused for this type of RoPE.
|
|
rope_kwargs (`Dict`, *optional*):
|
|
BC compatibility with the previous RoPE class instantiation, will be removed in v4.45.
|
|
Returns:
|
|
Tuple of (`torch.Tensor`, `float`), containing the inverse frequencies for the RoPE embeddings and the
|
|
post-processing scaling factor applied to the computed cos/sin.
|
|
"""
|
|
# Gets the default RoPE parameters
|
|
inv_freq, attention_factor = _compute_default_rope_parameters(
|
|
config, device, seq_len, **rope_kwargs
|
|
)
|
|
|
|
factor = config.rope_scaling["factor"] # `8` in the original implementation
|
|
low_freq_factor = config.rope_scaling[
|
|
"low_freq_factor"
|
|
] # `1` in the original implementation
|
|
high_freq_factor = config.rope_scaling[
|
|
"high_freq_factor"
|
|
] # `4` in the original implementation
|
|
old_context_len = config.rope_scaling[
|
|
"original_max_position_embeddings"
|
|
] # `8192` in the original implementation
|
|
|
|
low_freq_wavelen = old_context_len / low_freq_factor
|
|
high_freq_wavelen = old_context_len / high_freq_factor
|
|
|
|
wavelen = 2 * math.pi / inv_freq
|
|
# wavelen < high_freq_wavelen: do nothing
|
|
# wavelen > low_freq_wavelen: divide by factor
|
|
inv_freq_llama = torch.where(
|
|
wavelen > low_freq_wavelen, inv_freq / factor, inv_freq
|
|
)
|
|
# otherwise: interpolate between the two, using a smooth factor
|
|
smooth_factor = (old_context_len / wavelen - low_freq_factor) / (
|
|
high_freq_factor - low_freq_factor
|
|
)
|
|
smoothed_inv_freq = (
|
|
1 - smooth_factor
|
|
) * inv_freq_llama / factor + smooth_factor * inv_freq_llama
|
|
is_medium_freq = ~(wavelen < high_freq_wavelen) * ~(wavelen > low_freq_wavelen)
|
|
inv_freq_llama = torch.where(is_medium_freq, smoothed_inv_freq, inv_freq_llama)
|
|
|
|
return inv_freq_llama, attention_factor
|
|
|
|
|
|
# This maps the "rope_type" string field in rope config to the corresponding function to compute the RoPE parameters
|
|
# from the model config. You can append new {'rope_type': callable} pairs to this dictionary to enable custom RoPE
|
|
# parameterizations, as long as the callable has the same signature.
|
|
ROPE_INIT_FUNCTIONS = {
|
|
"default": _compute_default_rope_parameters,
|
|
"linear": _compute_linear_scaling_rope_parameters,
|
|
"dynamic": _compute_dynamic_ntk_parameters,
|
|
"yarn": _compute_yarn_parameters,
|
|
"longrope": _compute_longrope_parameters,
|
|
"llama3": _compute_llama3_parameters,
|
|
}
|
|
|
|
|
|
def _check_received_keys(
|
|
rope_type: str,
|
|
received_keys: set,
|
|
required_keys: set,
|
|
optional_keys: set | None = None,
|
|
ignore_keys: set | None = None,
|
|
):
|
|
"""Compare the received keys in `config.rope_scaling` against the expected and optional keys"""
|
|
# BC: "rope_type" was originally "type" -- let's check for "rope_type" when "type" is present
|
|
if "type" in received_keys:
|
|
received_keys -= {"type"}
|
|
required_keys.add("rope_type")
|
|
|
|
# Some models need to store model-specific keys, and we don't want to throw warning at them
|
|
if ignore_keys is not None:
|
|
received_keys -= ignore_keys
|
|
|
|
missing_keys = required_keys - received_keys
|
|
if missing_keys:
|
|
raise KeyError(
|
|
f"Missing required keys in `rope_scaling` for 'rope_type'='{rope_type}': {missing_keys}"
|
|
)
|
|
|
|
if optional_keys is not None:
|
|
unused_keys = received_keys - required_keys - optional_keys
|
|
else:
|
|
unused_keys = received_keys - required_keys
|
|
if unused_keys:
|
|
logger.warning(
|
|
"Unrecognized keys in `rope_scaling` for 'rope_type'='%s': %s",
|
|
rope_type,
|
|
unused_keys,
|
|
)
|
|
|
|
|
|
def _validate_default_rope_parameters(
|
|
config: PretrainedConfig, ignore_keys: set | None = None
|
|
):
|
|
rope_scaling = config.rope_scaling
|
|
rope_type = rope_scaling.get(
|
|
"rope_type", rope_scaling.get("type", None)
|
|
) # BC: "rope_type" was originally "type"
|
|
required_keys = {"rope_type"}
|
|
received_keys = set(rope_scaling.keys())
|
|
_check_received_keys(
|
|
rope_type, received_keys, required_keys, ignore_keys=ignore_keys
|
|
)
|
|
|
|
|
|
def _validate_linear_scaling_rope_parameters(
|
|
config: PretrainedConfig, ignore_keys: set | None = None
|
|
):
|
|
rope_scaling = config.rope_scaling
|
|
rope_type = rope_scaling.get(
|
|
"rope_type", rope_scaling.get("type", None)
|
|
) # BC: "rope_type" was originally "type"
|
|
required_keys = {"rope_type", "factor"}
|
|
received_keys = set(rope_scaling.keys())
|
|
_check_received_keys(
|
|
rope_type, received_keys, required_keys, ignore_keys=ignore_keys
|
|
)
|
|
|
|
factor = rope_scaling["factor"]
|
|
if factor is None or not isinstance(factor, float) or factor < 1.0:
|
|
logger.warning(
|
|
"`rope_scaling`'s factor field must be a float >= 1, got %s", factor
|
|
)
|
|
|
|
|
|
def _validate_dynamic_scaling_rope_parameters(
|
|
config: PretrainedConfig, ignore_keys: set | None = None
|
|
):
|
|
rope_scaling = config.rope_scaling
|
|
rope_type = rope_scaling.get(
|
|
"rope_type", rope_scaling.get("type", None)
|
|
) # BC: "rope_type" was originally "type"
|
|
required_keys = {"rope_type", "factor"}
|
|
optional_keys = {"original_max_position_embeddings"}
|
|
received_keys = set(rope_scaling.keys())
|
|
_check_received_keys(
|
|
rope_type, received_keys, required_keys, optional_keys, ignore_keys=ignore_keys
|
|
)
|
|
|
|
factor = rope_scaling["factor"]
|
|
if factor is None or not isinstance(factor, float) or factor < 1.0:
|
|
logger.warning(
|
|
"`rope_scaling`'s factor field must be a float >= 1, got %s", factor
|
|
)
|
|
|
|
|
|
def _validate_yarn_parameters(config: PretrainedConfig, ignore_keys: set | None = None):
|
|
rope_scaling = config.rope_scaling
|
|
rope_type = rope_scaling.get(
|
|
"rope_type", rope_scaling.get("type", None)
|
|
) # BC: "rope_type" was originally "type"
|
|
required_keys = {"rope_type", "factor"}
|
|
optional_keys = {
|
|
"attention_factor",
|
|
"beta_fast",
|
|
"beta_slow",
|
|
"original_max_position_embeddings",
|
|
"mscale",
|
|
"mscale_all_dim",
|
|
}
|
|
received_keys = set(rope_scaling.keys())
|
|
_check_received_keys(
|
|
rope_type, received_keys, required_keys, optional_keys, ignore_keys=ignore_keys
|
|
)
|
|
|
|
factor = rope_scaling["factor"]
|
|
if factor is None or not isinstance(factor, float) or factor < 1.0:
|
|
logger.warning(
|
|
"`rope_scaling`'s factor field must be a float >= 1, got %s", factor
|
|
)
|
|
|
|
attention_factor = rope_scaling.get("attention_factor")
|
|
if attention_factor is not None and (
|
|
not isinstance(attention_factor, float) or attention_factor < 0
|
|
):
|
|
logger.warning(
|
|
"`rope_scaling`'s attention_factor field must be a float greater than 0, got %s",
|
|
attention_factor,
|
|
)
|
|
beta_fast = rope_scaling.get("beta_fast")
|
|
if beta_fast is not None and not isinstance(beta_fast, float):
|
|
logger.warning(
|
|
"`rope_scaling`'s beta_fast field must be a float, got %s", beta_fast
|
|
)
|
|
beta_slow = rope_scaling.get("beta_slow")
|
|
if beta_slow is not None and not isinstance(beta_slow, float):
|
|
logger.warning(
|
|
"`rope_scaling`'s beta_slow field must be a float, got %s", beta_slow
|
|
)
|
|
|
|
if (beta_fast or 32) < (beta_slow or 1):
|
|
logger.warning(
|
|
"`rope_scaling`'s beta_fast field must be greater than beta_slow, got beta_fast=%s (defaults to 32 if None) and beta_slow=%s (defaults to 1 if None)",
|
|
beta_fast,
|
|
beta_slow,
|
|
)
|
|
|
|
|
|
def _validate_longrope_parameters(
|
|
config: PretrainedConfig, ignore_keys: set | None = None
|
|
):
|
|
rope_scaling = config.rope_scaling
|
|
rope_type = rope_scaling.get(
|
|
"rope_type", rope_scaling.get("type", None)
|
|
) # BC: "rope_type" was originally "type"
|
|
required_keys = {"rope_type", "short_factor", "long_factor"}
|
|
optional_keys = {"attention_factor", "factor", "original_max_position_embeddings"}
|
|
received_keys = set(rope_scaling.keys())
|
|
_check_received_keys(
|
|
rope_type, received_keys, required_keys, optional_keys, ignore_keys=ignore_keys
|
|
)
|
|
|
|
partial_rotary_factor = (
|
|
config.partial_rotary_factor
|
|
if hasattr(config, "partial_rotary_factor")
|
|
else 1.0
|
|
)
|
|
head_dim = getattr(
|
|
config, "head_dim", config.hidden_size // config.num_attention_heads
|
|
)
|
|
dim = int(head_dim * partial_rotary_factor)
|
|
|
|
short_factor = rope_scaling.get("short_factor")
|
|
if not isinstance(short_factor, list) and all(
|
|
isinstance(x, (int, float)) for x in short_factor
|
|
):
|
|
logger.warning(
|
|
"`rope_scaling`'s short_factor field must be a list of numbers, got %s",
|
|
short_factor,
|
|
)
|
|
if not len(short_factor) == dim // 2:
|
|
logger.warning(
|
|
"`rope_scaling`'s short_factor field must have length %s, got %s",
|
|
dim // 2,
|
|
len(short_factor),
|
|
)
|
|
|
|
long_factor = rope_scaling.get("long_factor")
|
|
if not isinstance(long_factor, list) and all(
|
|
isinstance(x, (int, float)) for x in long_factor
|
|
):
|
|
logger.warning(
|
|
"`rope_scaling`'s long_factor field must be a list of numbers, got %s",
|
|
long_factor,
|
|
)
|
|
if not len(long_factor) == dim // 2:
|
|
logger.warning(
|
|
"`rope_scaling`'s long_factor field must have length %s, got %s",
|
|
dim // 2,
|
|
len(long_factor),
|
|
)
|
|
|
|
# Handle Phi3 divergence: prefer the use of `attention_factor` and/or `factor` over
|
|
# `original_max_position_embeddings` to compute internal variables. The latter lives outside `rope_scaling` and is
|
|
# unique to longrope (= undesirable)
|
|
if hasattr(config, "original_max_position_embeddings"):
|
|
logger.warning_once(
|
|
"This model has set a `original_max_position_embeddings` field, to be used together with "
|
|
"`max_position_embeddings` to determine a scaling factor. Please set the `factor` field of `rope_scaling`"
|
|
"with this ratio instead -- we recommend the use of this field over `original_max_position_embeddings`, "
|
|
"as it is compatible with most model architectures."
|
|
)
|
|
else:
|
|
factor = rope_scaling.get("factor")
|
|
if factor is None:
|
|
logger.warning("Missing required keys in `rope_scaling`: 'factor'")
|
|
elif not isinstance(factor, float) or factor < 1.0:
|
|
logger.warning(
|
|
"`rope_scaling`'s factor field must be a float >= 1, got %s", factor
|
|
)
|
|
|
|
attention_factor = rope_scaling.get("attention_factor")
|
|
if attention_factor is not None:
|
|
if not isinstance(attention_factor, float) or attention_factor < 0.0:
|
|
logger.warning(
|
|
"`rope_scaling`'s attention_factor field must be a float greater than 0, got %s",
|
|
attention_factor,
|
|
)
|
|
|
|
|
|
def _validate_llama3_parameters(
|
|
config: PretrainedConfig, ignore_keys: set | None = None
|
|
):
|
|
rope_scaling = config.rope_scaling
|
|
rope_type = rope_scaling.get(
|
|
"rope_type", rope_scaling.get("type", None)
|
|
) # BC: "rope_type" was originally "type"
|
|
required_keys = {
|
|
"rope_type",
|
|
"factor",
|
|
"original_max_position_embeddings",
|
|
"low_freq_factor",
|
|
"high_freq_factor",
|
|
}
|
|
received_keys = set(rope_scaling.keys())
|
|
_check_received_keys(
|
|
rope_type, received_keys, required_keys, ignore_keys=ignore_keys
|
|
)
|
|
|
|
factor = rope_scaling["factor"]
|
|
if factor is None or not isinstance(factor, float) or factor < 1.0:
|
|
logger.warning(
|
|
"`rope_scaling`'s factor field must be a float >= 1, got %s", factor
|
|
)
|
|
|
|
low_freq_factor = rope_scaling["low_freq_factor"]
|
|
high_freq_factor = rope_scaling["high_freq_factor"]
|
|
if low_freq_factor is None or not isinstance(low_freq_factor, float):
|
|
logger.warning(
|
|
"`rope_scaling`'s low_freq_factor field must be a float, got %s",
|
|
low_freq_factor,
|
|
)
|
|
if high_freq_factor is None or not isinstance(high_freq_factor, float):
|
|
logger.warning(
|
|
"`rope_scaling`'s high_freq_factor field must be a float, got %s",
|
|
high_freq_factor,
|
|
)
|
|
if high_freq_factor <= low_freq_factor:
|
|
logger.warning(
|
|
"`rope_scaling`'s high_freq_factor field must be greater than low_freq_factor, got high_freq_factor=%s and low_freq_factor=%s",
|
|
high_freq_factor,
|
|
low_freq_factor,
|
|
)
|
|
|
|
original_max_position_embeddings = rope_scaling["original_max_position_embeddings"]
|
|
if original_max_position_embeddings is None or not isinstance(
|
|
original_max_position_embeddings, int
|
|
):
|
|
logger.warning(
|
|
"`rope_scaling`'s original_max_position_embeddings field must be an integer, got %s",
|
|
original_max_position_embeddings,
|
|
)
|
|
if original_max_position_embeddings >= config.max_position_embeddings:
|
|
logger.warning(
|
|
"`rope_scaling`'s original_max_position_embeddings field must be less than max_position_embeddings, got %s and max_position_embeddings=%s",
|
|
original_max_position_embeddings,
|
|
config.max_position_embeddings,
|
|
)
|
|
|
|
|
|
# Like `ROPE_INIT_FUNCTIONS`, this validation function mapping can be dynamically updated for custom RoPE types.
|
|
ROPE_VALIDATION_FUNCTIONS = {
|
|
"default": _validate_default_rope_parameters,
|
|
"linear": _validate_linear_scaling_rope_parameters,
|
|
"dynamic": _validate_dynamic_scaling_rope_parameters,
|
|
"yarn": _validate_yarn_parameters,
|
|
"longrope": _validate_longrope_parameters,
|
|
"llama3": _validate_llama3_parameters,
|
|
}
|
|
|
|
|
|
def rope_config_validation(config: PretrainedConfig, ignore_keys: set | None = None):
|
|
"""
|
|
Validate the RoPE config arguments, given a `PretrainedConfig` object
|
|
"""
|
|
rope_scaling = getattr(
|
|
config, "rope_scaling", None
|
|
) # not a default parameter in `PretrainedConfig`
|
|
if rope_scaling is None:
|
|
return
|
|
|
|
# BC: "rope_type" was originally "type"
|
|
rope_type = rope_scaling.get("rope_type", rope_scaling.get("type", "default"))
|
|
validation_fn = ROPE_VALIDATION_FUNCTIONS.get(rope_type)
|
|
if validation_fn is not None:
|
|
validation_fn(config, ignore_keys=ignore_keys)
|
|
else:
|
|
logger.warning(
|
|
"Missing validation function mapping in `ROPE_VALIDATION_FUNCTIONS` for 'rope_type'='%s'",
|
|
rope_type,
|
|
)
|