adyoi commited on
Commit
6326055
·
verified ·
1 Parent(s): 2522411

Upload folder using huggingface_hub

Browse files
Files changed (9) hide show
  1. .gitignore +5 -0
  2. data/sample.txt +50 -0
  3. developments.txt +29 -0
  4. generate.py +34 -0
  5. indigo/__init__.py +4 -0
  6. indigo/model.py +121 -0
  7. indigo/tokenizer.py +33 -0
  8. requirements.txt +1 -0
  9. train.py +125 -0
.gitignore ADDED
@@ -0,0 +1,5 @@
 
 
 
 
 
 
1
+ __pycache__/
2
+ *.pyc
3
+ out/
4
+ *.pt
5
+ .git/
data/sample.txt ADDED
@@ -0,0 +1,50 @@
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
1
+ Indigo adalah model bahasa kecil yang dibangun dari nol.
2
+ Model ini dilatih dengan PyTorch murni tanpa pustaka tambahan.
3
+ Arsitektur Indigo berupa transformer decoder sederhana.
4
+ Setiap blok transformer memuat perhatian kausal dan jaringan saraf.
5
+ Perhatian kausal membuat model hanya melihat token masa lalu.
6
+ Token masa lalu dipakai untuk memprediksi token berikutnya.
7
+ Prediksi token berikutnya adalah inti dari pemodelan bahasa.
8
+ Pemodelan bahasa bisa dipakai untuk membuat teks baru.
9
+ Teks baru dihasilkan token demi token secara berurutan.
10
+ Urutan token ditentukan oleh distribusi probabilitas model.
11
+ Probabilitas model dipelajari dari data latih.
12
+ Data latih berupa kumpulan teks biasa dalam berkas txt.
13
+ Berkas teks dibaca lalu diubah menjadi deret angka.
14
+ Deret angka tersebut menjadi masukan bagi jaringan saraf.
15
+ Jaringan saraf belajar dengan menurunkan fungsi kerugian.
16
+ Fungsi kerugian dihitung menggunakan cross entropy.
17
+ Cross entropy mengukur selisih prediksi dengan jawaban sebenarnya.
18
+ Jawaban sebenarnya adalah token yang muncul pada data asli.
19
+ Data asli dibagi menjadi data latih dan data validasi.
20
+ Data validasi dipakai untuk memantau kemajuan pelatihan.
21
+ Pelatihan berjalan selama ribuan langkah kecil.
22
+ Setiap langkah memperbarui bobot model sedikit demi sedikit.
23
+ Bobot model diperbarui oleh optimizer AdamW.
24
+ Optimizer menurunkan kerugian dengan gradien turun.
25
+ Gradien dihitung lewat propagasi balik otomatis dari PyTorch.
26
+ Propagasi balik meneruskan kesalahan ke setiap lapisan.
27
+ Lapisan pertama adalah lapisan penyematan token.
28
+ Penyematan token mengubah angka menjadi vektor padat.
29
+ Vektor padat digabung dengan penyematan posisi.
30
+ Penyematan posisi memberi tahu urutan kata dalam kalimat.
31
+ Kalimat panjang dipotong menjadi jendela tetap.
32
+ Jendela tetap disebut block size atau konteks.
33
+ Konteks dibatasi agar perhatian tetap efisien.
34
+ Perhatian menghitung hubungan antar token dalam konteks.
35
+ Hubungan antar token membentuk pemahaman sederhana.
36
+ Pemahaman ini tumbuh seiring bertambahnya langkah latih.
37
+ Langkah latih dicatat beserta nilai kerugiannya.
38
+ Nilai kerugian yang menurun menandakan model belajar.
39
+ Model yang sudah belajar bisa menyimpan checkpoint.
40
+ Checkpoint berisi bobot, konfigurasi, dan kosakata.
41
+ Kosakata Indigo berupa karakter unik dari data.
42
+ Tokenizer karakter mengubah huruf menjadi angka sederhana.
43
+ Angka sederhana mudah dipahami tanpa pustaka eksternal.
44
+ Tanpa pustaka eksternal proyek tetap ringan dan jelas.
45
+ Proyek ringan cocok untuk belajar dari dasar.
46
+ Dasar yang kuat memudahkan eksperimen lanjutan.
47
+ Eksperimen bisa berupa penambahan lapisan atau kepala perhatian.
48
+ Kepala perhatian tambahan menangkap pola yang lebih beragam.
49
+ Pola beragam menghasilkan teks yang lebih koheren.
50
+ Teks koheren adalah tujuan akhir dari pelatihan ini.
developments.txt ADDED
@@ -0,0 +1,29 @@
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
1
+
2
+ Sekarang smoke test training singkat untuk memastikan pipeline jalan:
3
+
4
+ python train.py
5
+ --data data/sample.txt
6
+ --out out_smoke
7
+ --steps 80
8
+ --batch-size 16
9
+ --block-size 64
10
+ --n-layer 2
11
+ --n-head 2
12
+ --n-embd 64
13
+ --warmup 10
14
+ --eval-interval 40
15
+
16
+
17
+ Loss turun (3.93 → 3.08) — pipeline bekerja. Tes generasi:
18
+
19
+ python generate.py
20
+ --ckpt out_smoke/indigo.pt
21
+ --prompt "Indigo"
22
+ --max-new 80
23
+ --temperature 0.8
24
+ --top-k 20
25
+ --seed 42
26
+
27
+ Generasi berfungsi (masih acak karena hanya 80 langkah). Sekarang latih versi asli dengan konfigurasi lebih besar:
28
+
29
+ Remove-Item -Recurse -Force out_smoke
generate.py ADDED
@@ -0,0 +1,34 @@
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
1
+ import argparse
2
+
3
+ import torch
4
+
5
+ from indigo.model import GPT, GPTConfig
6
+ from indigo.tokenizer import CharTokenizer
7
+
8
+
9
+ def main():
10
+ parser = argparse.ArgumentParser(description="Generate teks dari checkpoint Indigo")
11
+ parser.add_argument("--ckpt", default="out/indigo.pt")
12
+ parser.add_argument("--prompt", default="")
13
+ parser.add_argument("--max-new", type=int, default=300)
14
+ parser.add_argument("--temperature", type=float, default=0.8)
15
+ parser.add_argument("--top-k", type=int, default=40)
16
+ parser.add_argument("--seed", type=int, default=None)
17
+ args = parser.parse_args()
18
+
19
+ if args.seed is not None:
20
+ torch.manual_seed(args.seed)
21
+
22
+ ckpt = torch.load(args.ckpt, map_location="cpu", weights_only=True)
23
+ model = GPT(GPTConfig(**ckpt["config"]))
24
+ model.load_state_dict(ckpt["model"])
25
+ tokenizer = CharTokenizer(ckpt["vocab"])
26
+
27
+ ids = tokenizer.encode(args.prompt) or [0]
28
+ idx = torch.tensor([ids], dtype=torch.long)
29
+ out = model.generate(idx, args.max_new, temperature=args.temperature, top_k=args.top_k)
30
+ print(tokenizer.decode(out[0].tolist()))
31
+
32
+
33
+ if __name__ == "__main__":
34
+ main()
indigo/__init__.py ADDED
@@ -0,0 +1,4 @@
 
 
 
 
 
1
+ from .model import GPT, GPTConfig
2
+ from .tokenizer import CharTokenizer
3
+
4
+ __all__ = ["GPT", "GPTConfig", "CharTokenizer"]
indigo/model.py ADDED
@@ -0,0 +1,121 @@
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
1
+ import math
2
+ from dataclasses import dataclass
3
+
4
+ import torch
5
+ import torch.nn as nn
6
+ import torch.nn.functional as F
7
+
8
+
9
+ @dataclass
10
+ class GPTConfig:
11
+ vocab_size: int = 256
12
+ block_size: int = 128
13
+ n_layer: int = 4
14
+ n_head: int = 4
15
+ n_embd: int = 128
16
+ dropout: float = 0.1
17
+ bias: bool = False
18
+
19
+
20
+ class CausalSelfAttention(nn.Module):
21
+ def __init__(self, config):
22
+ super().__init__()
23
+ assert config.n_embd % config.n_head == 0
24
+ self.n_head = config.n_head
25
+ self.n_embd = config.n_embd
26
+ self.qkv = nn.Linear(config.n_embd, 3 * config.n_embd, bias=config.bias)
27
+ self.proj = nn.Linear(config.n_embd, config.n_embd, bias=config.bias)
28
+ self.attn_dropout = nn.Dropout(config.dropout)
29
+ self.resid_dropout = nn.Dropout(config.dropout)
30
+ mask = torch.tril(torch.ones(config.block_size, config.block_size))
31
+ self.register_buffer("mask", mask.view(1, 1, config.block_size, config.block_size))
32
+
33
+ def forward(self, x):
34
+ B, T, C = x.shape
35
+ q, k, v = self.qkv(x).split(self.n_embd, dim=2)
36
+ q = q.view(B, T, self.n_head, C // self.n_head).transpose(1, 2)
37
+ k = k.view(B, T, self.n_head, C // self.n_head).transpose(1, 2)
38
+ v = v.view(B, T, self.n_head, C // self.n_head).transpose(1, 2)
39
+ att = (q @ k.transpose(-2, -1)) * (1.0 / math.sqrt(k.size(-1)))
40
+ att = att.masked_fill(self.mask[:, :, :T, :T] == 0, float("-inf"))
41
+ att = F.softmax(att, dim=-1)
42
+ att = self.attn_dropout(att)
43
+ y = (att @ v).transpose(1, 2).contiguous().view(B, T, C)
44
+ return self.resid_dropout(self.proj(y))
45
+
46
+
47
+ class MLP(nn.Module):
48
+ def __init__(self, config):
49
+ super().__init__()
50
+ self.fc = nn.Linear(config.n_embd, 4 * config.n_embd, bias=config.bias)
51
+ self.proj = nn.Linear(4 * config.n_embd, config.n_embd, bias=config.bias)
52
+ self.drop = nn.Dropout(config.dropout)
53
+
54
+ def forward(self, x):
55
+ return self.drop(self.proj(F.gelu(self.fc(x))))
56
+
57
+
58
+ class Block(nn.Module):
59
+ def __init__(self, config):
60
+ super().__init__()
61
+ self.ln1 = nn.LayerNorm(config.n_embd, bias=config.bias)
62
+ self.attn = CausalSelfAttention(config)
63
+ self.ln2 = nn.LayerNorm(config.n_embd, bias=config.bias)
64
+ self.mlp = MLP(config)
65
+
66
+ def forward(self, x):
67
+ x = x + self.attn(self.ln1(x))
68
+ x = x + self.mlp(self.ln2(x))
69
+ return x
70
+
71
+
72
+ class GPT(nn.Module):
73
+ def __init__(self, config):
74
+ super().__init__()
75
+ self.config = config
76
+ self.tok_emb = nn.Embedding(config.vocab_size, config.n_embd)
77
+ self.pos_emb = nn.Embedding(config.block_size, config.n_embd)
78
+ self.drop = nn.Dropout(config.dropout)
79
+ self.blocks = nn.ModuleList([Block(config) for _ in range(config.n_layer)])
80
+ self.ln_f = nn.LayerNorm(config.n_embd, bias=config.bias)
81
+ self.head = nn.Linear(config.n_embd, config.vocab_size, bias=False)
82
+ self.head.weight = self.tok_emb.weight
83
+ self.apply(self._init_weights)
84
+
85
+ def _init_weights(self, module):
86
+ if isinstance(module, nn.Linear):
87
+ nn.init.normal_(module.weight, mean=0.0, std=0.02)
88
+ if module.bias is not None:
89
+ nn.init.zeros_(module.bias)
90
+ elif isinstance(module, nn.Embedding):
91
+ nn.init.normal_(module.weight, mean=0.0, std=0.02)
92
+
93
+ def forward(self, idx, targets=None):
94
+ B, T = idx.shape
95
+ pos = torch.arange(T, device=idx.device)
96
+ x = self.drop(self.tok_emb(idx) + self.pos_emb(pos))
97
+ for block in self.blocks:
98
+ x = block(x)
99
+ logits = self.head(self.ln_f(x))
100
+ loss = None
101
+ if targets is not None:
102
+ loss = F.cross_entropy(logits.reshape(-1, logits.size(-1)), targets.reshape(-1))
103
+ return logits, loss
104
+
105
+ @torch.no_grad()
106
+ def generate(self, idx, max_new_tokens, temperature=1.0, top_k=None):
107
+ self.eval()
108
+ for _ in range(max_new_tokens):
109
+ idx_cond = idx[:, -self.config.block_size:]
110
+ logits, _ = self(idx_cond)
111
+ logits = logits[:, -1, :] / max(temperature, 1e-8)
112
+ if top_k is not None:
113
+ v, _ = torch.topk(logits, min(top_k, logits.size(-1)))
114
+ logits[logits < v[:, [-1]]] = float("-inf")
115
+ probs = F.softmax(logits, dim=-1)
116
+ next_id = torch.multinomial(probs, num_samples=1)
117
+ idx = torch.cat((idx, next_id), dim=1)
118
+ return idx
119
+
120
+ def num_params(self):
121
+ return sum(p.numel() for p in self.parameters())
indigo/tokenizer.py ADDED
@@ -0,0 +1,33 @@
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
1
+ import json
2
+
3
+
4
+ class CharTokenizer:
5
+ def __init__(self, vocab=None):
6
+ if vocab is None:
7
+ self.itos = []
8
+ else:
9
+ self.itos = list(vocab)
10
+ self.stoi = {ch: i for i, ch in enumerate(self.itos)}
11
+
12
+ @classmethod
13
+ def from_text(cls, text):
14
+ return cls(sorted(set(text)))
15
+
16
+ @property
17
+ def vocab_size(self):
18
+ return len(self.itos)
19
+
20
+ def encode(self, text):
21
+ return [self.stoi[ch] for ch in text if ch in self.stoi]
22
+
23
+ def decode(self, ids):
24
+ return "".join(self.itos[i] for i in ids)
25
+
26
+ def save(self, path):
27
+ with open(path, "w", encoding="utf-8") as f:
28
+ json.dump(self.itos, f, ensure_ascii=False)
29
+
30
+ @classmethod
31
+ def load(cls, path):
32
+ with open(path, encoding="utf-8") as f:
33
+ return cls(json.load(f))
requirements.txt ADDED
@@ -0,0 +1 @@
 
 
1
+ torch>=2.0
train.py ADDED
@@ -0,0 +1,125 @@
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
1
+ import argparse
2
+ import math
3
+ import os
4
+ import time
5
+
6
+ import torch
7
+
8
+ from indigo.model import GPT, GPTConfig
9
+ from indigo.tokenizer import CharTokenizer
10
+
11
+
12
+ def get_batch(data, block_size, batch_size, device):
13
+ ix = torch.randint(len(data) - block_size - 1, (batch_size,))
14
+ x = torch.stack([data[i : i + block_size] for i in ix])
15
+ y = torch.stack([data[i + 1 : i + block_size + 1] for i in ix])
16
+ return x.to(device, non_blocking=True), y.to(device, non_blocking=True)
17
+
18
+
19
+ @torch.no_grad()
20
+ def estimate_loss(model, data, args, device):
21
+ model.eval()
22
+ losses = []
23
+ for _ in range(args.eval_iters):
24
+ x, y = get_batch(data, args.block_size, args.batch_size, device)
25
+ _, loss = model(x, y)
26
+ losses.append(loss.item())
27
+ model.train()
28
+ return sum(losses) / len(losses)
29
+
30
+
31
+ def main():
32
+ parser = argparse.ArgumentParser(description="Latih model Indigo dari scratch")
33
+ parser.add_argument("--data", default="data/sample.txt", help="path file teks untuk training")
34
+ parser.add_argument("--out", default="out", help="folder output checkpoint")
35
+ parser.add_argument("--steps", type=int, default=2000)
36
+ parser.add_argument("--batch-size", type=int, default=32)
37
+ parser.add_argument("--block-size", type=int, default=128)
38
+ parser.add_argument("--n-layer", type=int, default=4)
39
+ parser.add_argument("--n-head", type=int, default=4)
40
+ parser.add_argument("--n-embd", type=int, default=128)
41
+ parser.add_argument("--dropout", type=float, default=0.1)
42
+ parser.add_argument("--lr", type=float, default=3e-4)
43
+ parser.add_argument("--warmup", type=int, default=100)
44
+ parser.add_argument("--weight-decay", type=float, default=0.1)
45
+ parser.add_argument("--eval-interval", type=int, default=200)
46
+ parser.add_argument("--eval-iters", type=int, default=20)
47
+ parser.add_argument("--seed", type=int, default=1337)
48
+ args = parser.parse_args()
49
+
50
+ torch.manual_seed(args.seed)
51
+ device = "cuda" if torch.cuda.is_available() else "cpu"
52
+ os.makedirs(args.out, exist_ok=True)
53
+
54
+ with open(args.data, encoding="utf-8") as f:
55
+ text = f.read()
56
+
57
+ tokenizer = CharTokenizer.from_text(text)
58
+ data = torch.tensor(tokenizer.encode(text), dtype=torch.long)
59
+ if len(data) < args.block_size * 2:
60
+ raise SystemExit(f"data terlalu pendek ({len(data)} token), minimal {args.block_size * 2}")
61
+ n = int(0.9 * len(data))
62
+ train_data, val_data = data[:n], data[n:]
63
+
64
+ config = GPTConfig(
65
+ vocab_size=tokenizer.vocab_size,
66
+ block_size=args.block_size,
67
+ n_layer=args.n_layer,
68
+ n_head=args.n_head,
69
+ n_embd=args.n_embd,
70
+ dropout=args.dropout,
71
+ )
72
+ model = GPT(config).to(device)
73
+ print(
74
+ f"device={device} | params={model.num_params() / 1e6:.2f}M | "
75
+ f"vocab={tokenizer.vocab_size} | tokens={len(data):,}"
76
+ )
77
+
78
+ optimizer = torch.optim.AdamW(
79
+ model.parameters(), lr=args.lr, betas=(0.9, 0.95), weight_decay=args.weight_decay
80
+ )
81
+
82
+ def lr_at(step):
83
+ if step < args.warmup:
84
+ return args.lr * (step + 1) / args.warmup
85
+ progress = (step - args.warmup) / max(1, args.steps - args.warmup)
86
+ return 0.1 * args.lr + 0.45 * args.lr * (1 + math.cos(math.pi * progress))
87
+
88
+ model.train()
89
+ t0 = time.time()
90
+ for step in range(args.steps):
91
+ lr = lr_at(step)
92
+ for g in optimizer.param_groups:
93
+ g["lr"] = lr
94
+ x, y = get_batch(train_data, args.block_size, args.batch_size, device)
95
+ _, loss = model(x, y)
96
+ optimizer.zero_grad(set_to_none=True)
97
+ loss.backward()
98
+ torch.nn.utils.clip_grad_norm_(model.parameters(), 1.0)
99
+ optimizer.step()
100
+
101
+ if step % args.eval_interval == 0 or step == args.steps - 1:
102
+ if len(val_data) > args.block_size + 1:
103
+ val_loss = estimate_loss(model, val_data, args, device)
104
+ val_str = f"{val_loss:.4f}"
105
+ else:
106
+ val_str = "n/a"
107
+ print(
108
+ f"step {step:5d}/{args.steps} | lr {lr:.2e} | "
109
+ f"loss {loss.item():.4f} | val {val_str} | {time.time() - t0:.1f}s"
110
+ )
111
+
112
+ ckpt_path = os.path.join(args.out, "indigo.pt")
113
+ torch.save(
114
+ {
115
+ "model": model.state_dict(),
116
+ "config": config.__dict__,
117
+ "vocab": tokenizer.itos,
118
+ },
119
+ ckpt_path,
120
+ )
121
+ print(f"checkpoint tersimpan di {ckpt_path}")
122
+
123
+
124
+ if __name__ == "__main__":
125
+ main()