Llama 2 관련하여 code 와 model architecture 부터 보고, paper 에서 training, tuning 관련 된 내용을 볼 예정이다.
Llama 1 과 관련하여 2 는 차이가 GQA (Groupted Query Attention) 이라는데, 둘다 합하여 못봤던 방법을 정리.
Input: Values of over a mini-batch:
Output:
def batch_norm(X, gamma, beta, eps, momentum):
if len(X.shape) == 2:
mean = X.mean(dim=0)
var = ((X - mean) ** 2).mean(dim=0)
else:
mean = X.mean(dim=(0, 2, 3), keepdim=True)
var = ((X - mean) ** 2).mean(dim=(0, 2, 3), keepdim=True)
X_hat = (X - mean) / torch.sqrt(var + eps)
Y = gamma * X_hat + beta
return Y
class RMSNorm(torch.nn.Module):
def __init__(self, dim: int, eps: float = 1e-6):
super().__init__()
self.eps = eps
self.weight = nn.Parameter(torch.ones(dim))
def _norm(self, x):
return x * torch.rsqrt(x.pow(2).mean(-1, keepdim=True) + self.eps)
def forward(self, x):
output = self._norm(x.float()).type_as(x)
return output * self.weight
paper : SwiGLU
Swish + GLU (Gated Linear Units)
class FeedForward(nn.Module):
def __init__(
self,
dim: int,
hidden_dim: int,
multiple_of: int,
ffn_dim_multiplier: Optional[float],
):
super().__init__()
hidden_dim = int(2 * hidden_dim / 3)
# custom dim factor multiplier
if ffn_dim_multiplier is not None:
hidden_dim = int(ffn_dim_multiplier * hidden_dim)
hidden_dim = multiple_of * ((hidden_dim + multiple_of - 1) // multiple_of)
self.w1 = ColumnParallelLinear(
dim, hidden_dim, bias=False, gather_output=False, init_method=lambda x: x
)
self.w2 = RowParallelLinear(
hidden_dim, dim, bias=False, input_is_parallel=True, init_method=lambda x: x
)
self.w3 = ColumnParallelLinear(
dim, hidden_dim, bias=False, gather_output=False, init_method=lambda x: x
)
def forward(self, x):
return self.w2(F.silu(self.w1(x)) * self.w3(x))
Positional Embedding 파트는 따로 post 를 하나 만들 예정이다.
기존의 Transformer Architecture 를 보면, ( transformer full model )
Encoder stack (BERT) 에서는 Input Embedding 다음,
Decoder stack (GPT) 에서는 Output Embedding 다음,
layer 에서 Positional Encoding 을 호출한 것을 볼 수 있다.
이 작업에서 서로 다른 frequencies 의 사인, 코사인 함수를 사용한다.
transformer PE 로 Absolute Position Embedding 으로, 절대적인 위치 정보를 갖는다.
이러한 경우 extrapolation 에 문제가 된다. 즉, 최대 길이로 학습되었다면 이상의 길이의 position embedding 은 본적이 없게 된다. 그 한계로 inference 시 이상의 문장이 들어오면 문제가 생긴다.
Relative Position Embedding 중 하나이다. 기존 RPE 는 모두 Additive 형태 이었는데, RoPE 는 Multiplicative + sinusoid 형태 이다. Position Embedding 에 대해서는 따로 post 를 할 예정이다.
query 에서 위치의 단어 임베딩과 key 에서 위치의 단어 임베딩의 내적을 함수로 변환하자는 뜻. 여기서 함수는 단어 임베딩들과 (상대적 위치) 만 가지고 정의하길 원한다.
2D Plane 의 기하학적 특성을 사용하면
여기서 는 복소수의 실수 파트 (real number) 이고, 는 의 켤레 복소수를 나타낸다. 는 이 아닌 상수. multiplication matrix 를 더 보면
affine-transformed 단어 임베딩 벡터를 위치 인덱스 의 각도 배수만큼 회전하고 따라서 Rotary Position Embedding 직관을 해석할 수 있다.
즉, 다시 말하면 는 affine transformed 인데 앞에
이 2D rotate matrix 이므로 회전 변환을 의미한다. 이것이 Rotary Position Embedding
의 아이디어.
이제 일반화를 시켜보자. 2D 의 결과를 가 짝수인, 임의의 로 일반화 하기 위해 차원의 공간을 하위공간으로 나누고, inner product 의 linearity 로 결합하여
여기서
사전 정의된 매개변수들 이 있는 rotary matrix (회전 행렬) 이다.
의 도식 그림은
self-attention 에 RoPE 를 적용하면
여기서
는 position 정보를 encoding 하는 과정에서 안정성을 보장하는 orthogonal matrix 이다. 그러나 이와 같은 행렬 곱셈을 직접 곱하여 적용하는 것은 계산상 효율적이지 않다.
일단, RoFormer 를 이 Post 에서 자세히 다룰 것은 아니고, Position Embedding Post 를 따로 만들어서 자세히 다루어볼 예정이다.
def reshape_for_broadcast(freqs_cis: torch.Tensor, x: torch.Tensor):
ndim = x.ndim
assert 0 <= 1 < ndim
assert freqs_cis.shape == (x.shape[1], x.shape[-1])
shape = [d if i == 1 or i == ndim - 1 else 1 for i, d in enumerate(x.shape)]
return freqs_cis.view(*shape)
def apply_rotary_emb(
xq: torch.Tensor,
xk: torch.Tensor,
freqs_cis: torch.Tensor,
) -> Tuple[torch.Tensor, torch.Tensor]:
xq_ = torch.view_as_complex(xq.float().reshape(*xq.shape[:-1], -1, 2))
xk_ = torch.view_as_complex(xk.float().reshape(*xk.shape[:-1], -1, 2))
freqs_cis = reshape_for_broadcast(freqs_cis, xq_)
xq_out = torch.view_as_real(xq_ * freqs_cis).flatten(3)
xk_out = torch.view_as_real(xk_ * freqs_cis).flatten(3)
return xq_out.type_as(xq), xk_out.type_as(xk)
이 code 에서 보면 궁금한 것은 위에서 설명한 rotary matrix 로 회전변환을 하는데, complex number 를 사용하여 구하는 것을 볼 수 있다. 무슨 관계가 있는지 확인해보자.
2D 설명으로 간단히 관계를 해석해보자. 는 orthogonal matrix 라고 하니 1로 맞춘다.
따라서
1. orthogonal rotation matrix 는 unit complex number 와 같다. 이런 intuition 으로 접근
2. rotary positional embedding 에서 as_complex
로 complex number 변환만 나온 이유
3. rotation 이 끝난 후, real part 와 imagenary part 를
4. 다시 as_real
로 돌아가서 기존 dimension 으로 바꾸는 작업을 진행
5. positional embeddings 를 구한다.
안에서 query
xq
와 keyxk
를 가지고 호출한다.
class Attention(nn.Module):
# ...
def forward(
self,
x: torch.Tensor,
start_pos: int,
freqs_cis: torch.Tensor,
mask: Optional[torch.Tensor],
):
# ...
# Rotary Positional Embeddings 에서 확인.
xq, xk = apply_rotary_emb(xq, xk, freqs_cis=freqs_cis)
self.cache_k = self.cache_k.to(xq)
self.cache_v = self.cache_v.to(xq)
self.cache_k[:bsz, start_pos : start_pos + seqlen] = xk
self.cache_v[:bsz, start_pos : start_pos + seqlen] = xv
keys = self.cache_k[:bsz, : start_pos + seqlen]
values = self.cache_v[:bsz, : start_pos + seqlen]
# repeat k/v heads if n_kv_heads < n_heads
keys = repeat_kv(keys, self.n_rep) # (bs, cache_len + seqlen, n_local_heads, head_dim)
values = repeat_kv(values, self.n_rep) # (bs, cache_len + seqlen, n_local_heads, head_dim)
Rotary position embedding 을 Attention layer 안에서 한다 apply_rotary_emb
. Attention layer 가 여러 개 일때, 각 layer 마다 매번 Position Information 을 Attention 수식에 넣어, 상대적(Relative) Position embedding 을 한다는 뜻.
paper : Grouped Query Attention (GQA)
qkv = (
self.qkv(x)
.reshape(B, N, 3, self.num_heads, self.num_hidden_dim_head)
.permute(2, 0, 3, 1, 4)
)
q, k, v = qkv.unbind(0) # make torchscript happy (cannot use tensor as tuple)
# trick here to make q@k.t more stable
attn = (q * self.scale) @ k.transpose(-2, -1)
attn = attn.softmax(dim=-1)
attn = self.attn_drop(attn)
x = (attn @ v).transpose(1, 2).reshape(B, N, C)
GQA 에서 사용할 변수 선언
# n_kv_heads (int): Number of key and value heads.
self.n_kv_heads = args.n_heads if args.n_kv_heads is None else args.n_kv_heads
# n_local_heads (int): Number of local query heads.
self.n_local_heads = args.n_heads // model_parallel_size
# n_local_kv_heads (int): Number of local key and value heads.
self.n_local_kv_heads = self.n_kv_heads // model_parallel_size
self.head_dim = args.dim // args.n_heads
# wq (ColumnParallelLinear): Linear transformation for queries.
self.wq = ColumnParallelLinear(args.dim, args.n_heads * self.head_dim, ...)
# wk (ColumnParallelLinear): Linear transformation for keys.
self.wk = ColumnParallelLinear(args.dim, self.n_kv_heads * self.head_dim, ...)
# wv (ColumnParallelLinear): Linear transformation for values.
self.wv = ColumnParallelLinear(args.dim, self.n_kv_heads * self.head_dim, ...)
self.cache_k = torch.zeros((..., self.n_local_kv_heads, self.head_dim)).cuda()
self.cache_v = torch.zeros((..., self.n_local_kv_heads, self.head_dim)).cuda()
xq, xk, xv = self.wq(x), self.wk(x), self.wv(x)
xq = xq.view(bsz, seqlen, self.n_local_heads, self.head_dim)
xk = xk.view(bsz, seqlen, self.n_local_kv_heads, self.head_dim)
xv = xv.view(bsz, seqlen, self.n_local_kv_heads, self.head_dim)
Query 는
args.n_heads
를 사용하고, Key, Value 는self.n_kv_heads
를 사용했음을 알 수 있다.
local 은n_(*)heads
를model_parallel_size
로 나눈 몫이다.
Attention Algorithm
xq = xq.transpose(1, 2) # (bs, n_local_heads, seqlen, head_dim)
keys = keys.transpose(1, 2) # (bs, n_local_heads, cache_len + seqlen, head_dim)
values = values.transpose(1, 2) # (bs, n_local_heads, cache_len + seqlen, head_dim)
scores = torch.matmul(xq, keys.transpose(2, 3)) / math.sqrt(self.head_dim)
if mask is not None:
scores = scores + mask # (bs, n_local_heads, seqlen, cache_len + seqlen)
scores = F.softmax(scores.float(), dim=-1).type_as(xq)
output = torch.matmul(scores, values) # (bs, n_local_heads, seqlen, head_dim)
class TransformerBlock(nn.Module):
def __init__(self, layer_id: int, args: ModelArgs):
# ...
self.attention = Attention(args)
self.feed_forward = FeedForward(
# ...
)
self.attention_norm = RMSNorm(args.dim, eps=args.norm_eps)
self.ffn_norm = RMSNorm(args.dim, eps=args.norm_eps)
def forward(
self,
x: torch.Tensor,
start_pos: int,
freqs_cis: torch.Tensor,
mask: Optional[torch.Tensor],
):
h = x + self.attention.forward(
self.attention_norm(x), start_pos, freqs_cis, mask
)
out = h + self.feed_forward.forward(self.ffn_norm(h))
return out
class Transformer(nn.Module):
def __init__(self, params: ModelArgs):
# ...
self.vocab_size = params.vocab_size
self.tok_embeddings = ParallelEmbedding(
# ...
)
self.layers = torch.nn.ModuleList()
for layer_id in range(params.n_layers):
self.layers.append(TransformerBlock(layer_id, params))
self.norm = RMSNorm(params.dim, eps=params.norm_eps)
self.output = ColumnParallelLinear(
params.dim, params.vocab_size, bias=False, init_method=lambda x: x
)
self.freqs_cis = precompute_freqs_cis(
self.params.dim // self.params.n_heads, self.params.max_seq_len * 2
)
@torch.inference_mode()
def forward(self, tokens: torch.Tensor, start_pos: int):
_bsz, seqlen = tokens.shape
h = self.tok_embeddings(tokens)
self.freqs_cis = self.freqs_cis.to(h.device)
freqs_cis = self.freqs_cis[start_pos : start_pos + seqlen]
# mask logic..
for layer in self.layers:
h = layer(h, start_pos, freqs_cis, mask)
h = self.norm(h)
output = self.output(h).float()
return output
TrnasformerBlock
으로 구성. attention_norm
으로 시작, feed_forward
로 block 마무리.self.output = ColumnParallelLinear
으로 Transformer 의 마지막이 linear 로 구성.Activation function (SwiGLU)
https://medium.com/@tariqanwarph/activation-function-and-glu-variants-for-transformer-models-a4fcbe85323f
GQA (Grouped Query Attention)
https://devocean.sk.com/blog/techBoardDetail.do?ID=165192&boardType=techBlog
Llama2 전반적인 모델 설명
https://velog.io/@alstjsdlr0321/Chapter-8.-LLaMA-2-Part1
Full model 그림 참조.
https://beeny-ds.tistory.com/entry/LLAMA-%EB%AA%A8%EB%8D%B8-%EA%B5%AC%EC%A1%B0-%ED%8C%8C%EC%95%85