OpenTransformer commited on
Commit
4180d1e
Β·
verified Β·
1 Parent(s): 844915a

Training script backup - 2026-03-06

Browse files
Files changed (1) hide show
  1. n_20260306.py +1044 -0
n_20260306.py ADDED
@@ -0,0 +1,1044 @@
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
1
+ #!/usr/bin/env python3
2
+
3
+ # n.py β€” Joint AR+SAT Trainer with Expansion Ratio Testing
4
+ # Enhanced inference: checkpoint name, tok/s, UK time
5
+
6
+ from __future__ import annotations
7
+ import argparse, json, math, pathlib, random, time, os, sys
8
+ from contextlib import nullcontext
9
+ from typing import Dict, Any, List, Optional, Tuple
10
+ from datetime import datetime, timezone
11
+ import torch
12
+
13
+ STATUS_FILE = "/workspace/status.json"
14
+
15
+ def write_status(step, seen_tok, loss, batch, block, tok_per_sec, phase):
16
+ import json as _json
17
+ try:
18
+ with open(STATUS_FILE, 'w') as f:
19
+ _json.dump({"step": step, "seen_tok": seen_tok, "loss": float(loss) if loss else None, "batch": batch, "block": block, "tok_per_sec": tok_per_sec, "phase": phase, "updated": time.time(), "target_tok": 35737600000}, f)
20
+ except: pass
21
+
22
+ def show_status():
23
+ import json as _json
24
+ try:
25
+ with open(STATUS_FILE) as f:
26
+ s = _json.load(f)
27
+ age = time.time() - s.get("updated", 0)
28
+ target = s.get("target_tok") or 35737600000
29
+ remaining = target - s.get("seen_tok", 0)
30
+ eta_sec = remaining / max(s.get("tok_per_sec", 1), 1)
31
+ eta_days = eta_sec / 86400
32
+ print(f"Step: {s.get('step', '?'):,} | Tokens: {s.get('seen_tok', 0)/1e9:.2f}B / {target/1e9:.1f}B | Loss: {s.get('loss', 0):.4f}")
33
+ print(f"Speed: {s.get('tok_per_sec', 0):.0f} tok/s | B={s.get('batch')} L={s.get('block')} | ETA: {eta_days:.1f} days | {age:.0f}s ago")
34
+ except FileNotFoundError:
35
+ print("No status file. Training not running?")
36
+ except Exception as e:
37
+ print(f"Error: {e}")
38
+
39
+ # SafeProgress - Claude-safe progress (discrete lines, not single growing line)
40
+ class SafeProgress:
41
+ def __init__(self, total, initial=0, unit="tok", print_every=500):
42
+ self.total, self.n, self.unit = total, initial, unit
43
+ self.last_print, self.postfix = initial, {}
44
+ self.start_time = __import__('time').time()
45
+ def update(self, n=1):
46
+ self.n += n
47
+ if self.n - self.last_print >= 1000000: # print every ~1M tokens
48
+ self._print(); self.last_print = self.n
49
+ def set_postfix(self, **kwargs): self.postfix = kwargs
50
+ def _print(self):
51
+ elapsed = __import__('time').time() - self.start_time
52
+ rate = self.n / elapsed if elapsed > 0 else 0
53
+ pct = 100 * self.n / self.total if self.total > 0 else 0
54
+ pf = ' '.join(f"{k}={v}" for k,v in self.postfix.items())
55
+ print(f"[{pct:.1f}%] {self.n:,}/{self.total:,} {self.unit} | {rate:.0f} tok/s | {pf}")
56
+ def close(self): self._print(); print("Done.")
57
+
58
+ import torch.nn as nn
59
+ import torch.nn.functional as F
60
+ from datasets import load_dataset, DownloadConfig
61
+ from transformers import AutoTokenizer, logging as hf_log
62
+ # from tqdm.auto import tqdm # DISABLED - kills Claude context
63
+
64
+ # DISABLED: # Auto-rotating log to prevent context-window suicide
65
+ # DISABLED: try:
66
+ # DISABLED: from rotating_log import install_rotating_log
67
+ # DISABLED: install_rotating_log()
68
+ # DISABLED: except ImportError:
69
+ # pass # Running without rotation
70
+
71
+ # ───────────────────────── ANSI Colors ─────────────────────────
72
+ class Colors:
73
+ RESET = "\033[0m"
74
+ BOLD = "\033[1m"
75
+ PROMPT = "\033[36m"
76
+ GEN = "\033[0m"
77
+ INFO = "\033[90m"
78
+ WARN = "\033[93m"
79
+
80
+ # ───────────────────────── Globals ─────────────────────────
81
+ hf_log.set_verbosity_error()
82
+ DEV = torch.device("cuda" if torch.cuda.is_available() else "cpu")
83
+ torch.backends.cuda.matmul.allow_tf32 = True
84
+ try:
85
+ torch.set_float32_matmul_precision("high")
86
+ except Exception:
87
+ pass
88
+
89
+ TOKENIZER_ID = os.environ.get("TOKENIZER_ID", "deepseek-ai/DeepSeek-V3.2")
90
+ tok = AutoTokenizer.from_pretrained(TOKENIZER_ID, use_fast=True, trust_remote_code=True)
91
+ if tok.pad_token is None:
92
+ tok.add_special_tokens({"pad_token": "<|pad|>"})
93
+
94
+ VOCAB, EOS = (
95
+ max(tok.get_vocab().values()) + 1,
96
+ tok.eos_token_id if tok.eos_token_id is not None else tok.sep_token_id
97
+ )
98
+
99
+ # ───────────────────────── PRESETS ─────────────────────────
100
+ PRESETS: Dict[str, Dict[str, int]] = {
101
+ "femto_1x": dict(d=16, layers=1, heads=1, rank=16),
102
+ "femto_12x": dict(d=16, layers=1, heads=1, rank=192),
103
+ "femto_24x": dict(d=16, layers=1, heads=1, rank=384),
104
+ "pico_1x": dict(d=32, layers=1, heads=2, rank=16),
105
+ "pico_3x": dict(d=32, layers=1, heads=2, rank=48),
106
+ "pico_6x": dict(d=32, layers=1, heads=2, rank=96),
107
+ "pico_12x": dict(d=32, layers=1, heads=2, rank=192),
108
+ "pico_24x": dict(d=32, layers=1, heads=2, rank=384),
109
+ "pico_48x": dict(d=32, layers=1, heads=2, rank=768),
110
+ "nano_1x": dict(d=64, layers=2, heads=4, rank=16),
111
+ "nano_3x": dict(d=64, layers=2, heads=4, rank=48),
112
+ "nano_6x": dict(d=64, layers=2, heads=4, rank=96),
113
+ "nano_12x": dict(d=64, layers=2, heads=4, rank=192),
114
+ "nano_24x": dict(d=64, layers=2, heads=4, rank=384),
115
+ "nano_48x": dict(d=64, layers=2, heads=4, rank=768),
116
+ "nano_96x": dict(d=64, layers=2, heads=4, rank=1536),
117
+ "micro_3x": dict(d=128, layers=4, heads=8, rank=48),
118
+ "micro_6x": dict(d=128, layers=4, heads=8, rank=96),
119
+ "micro_12x": dict(d=128, layers=4, heads=8, rank=192),
120
+ "micro_24x": dict(d=128, layers=4, heads=8, rank=384),
121
+ "small": dict(d=512, layers=8, heads=16, rank=64),
122
+ "smallx2": dict(d=512, layers=16, heads=16, rank=64),
123
+ "base": dict(d=768, layers=12, heads=24, rank=96),
124
+ "base18": dict(d=768, layers=18, heads=24, rank=96),
125
+ "large": dict(d=1024, layers=24, heads=16, rank=128),
126
+ }
127
+
128
+ DEFAULT_BLOCK = 1122
129
+ DEFAULT_BATCH = 1
130
+ SAT_BLOCK = 2
131
+ LR_CORE, LR_HEAD = 5e-5, 2e-4
132
+ EMIT_LAMBDA = 0.1
133
+ DEFAULT_SAVE_SEC = 24 * 3600
134
+ CKDIR = pathlib.Path("ckpts_expansion")
135
+
136
+ DEFAULT_PRETRAIN_SOURCES = "OpenTransformer/goddess-crawl,OpenTransformer/agillm-crawl-data,OpenTransformer/web-crawl-2026,OpenTransformer/web-crawl-clean-v2,OpenTransformer/scraped-web-data,OpenTransformer/turbo-crawl,OpenTransformer/sft-data-clean,OpenTransformer/web-crawl-v1"
137
+ DEFAULT_AFTER_SFT_SOURCES = "mlabonne/opc-sft-stage2-chat,HuggingFaceH4/ultrachat_200k"
138
+ DEFAULT_AFTER_SFT_BLOCK = 1122
139
+
140
+ # ───────────────────────── UK Time Helper ─────────────────────────
141
+ def get_uk_time() -> str:
142
+ utc_now = datetime.now(timezone.utc)
143
+ year = utc_now.year
144
+ march_last = datetime(year, 3, 31, 1, 0, tzinfo=timezone.utc)
145
+ while march_last.weekday() != 6:
146
+ march_last = march_last.replace(day=march_last.day - 1)
147
+ oct_last = datetime(year, 10, 31, 1, 0, tzinfo=timezone.utc)
148
+ while oct_last.weekday() != 6:
149
+ oct_last = oct_last.replace(day=oct_last.day - 1)
150
+ if march_last <= utc_now < oct_last:
151
+ uk_offset = 1
152
+ tz_name = "BST"
153
+ else:
154
+ uk_offset = 0
155
+ tz_name = "GMT"
156
+ from datetime import timedelta
157
+ uk_time = utc_now + timedelta(hours=uk_offset)
158
+ return uk_time.strftime(f'%Y-%m-%d %H:%M:%S {tz_name}')
159
+
160
+ # ───────────────────────── Utilities ─────────────────────────
161
+ def rng_state():
162
+ if DEV.type == "cuda":
163
+ try:
164
+ return torch.cuda.get_rng_state(DEV)
165
+ except TypeError:
166
+ return torch.cuda.get_rng_state()
167
+ return torch.get_rng_state()
168
+
169
+ def _is_probably_ckpt(path: pathlib.Path) -> bool:
170
+ try:
171
+ return path.is_file() and path.suffix == ".pt" and not path.name.endswith(".pt.tmp") and path.stat().st_size > (1<<20)
172
+ except Exception:
173
+ return False
174
+
175
+ def _resolve_ckpt(path: pathlib.Path) -> pathlib.Path | None:
176
+ try:
177
+ if path.is_dir():
178
+ cands = sorted([p for p in path.glob("*.pt") if _is_probably_ckpt(p)],
179
+ key=lambda p: p.stat().st_mtime, reverse=True)
180
+ return cands[0] if cands else None
181
+ if path.suffix == ".tmp":
182
+ solid = path.with_suffix("")
183
+ return solid if _is_probably_ckpt(solid) else _resolve_ckpt(path.parent)
184
+ return path if _is_probably_ckpt(path) else _resolve_ckpt(path.parent)
185
+ except Exception:
186
+ return None
187
+
188
+ def _try_load(path: pathlib.Path, map_location="cpu"):
189
+ try:
190
+ return torch.load(path, map_location="cpu")
191
+ except Exception as e:
192
+ print(f"[ckpt-skip] {path} not usable: {e}")
193
+ return None
194
+
195
+ def _prune_checkpoints(save_dir: pathlib.Path, phase_name: str, max_ckpts: int):
196
+ if max_ckpts is None or max_ckpts <= 0:
197
+ return
198
+ try:
199
+ # Clean stale .tmp files first
200
+ for tmp in save_dir.glob("*.pt.tmp"):
201
+ try:
202
+ tmp.unlink()
203
+ print(f" [prune] cleaned stale tmp {tmp.name}")
204
+ except Exception:
205
+ pass
206
+ pattern = f"{phase_name}_step*.pt"
207
+ ckpts = sorted(
208
+ [p for p in save_dir.glob(pattern) if _is_probably_ckpt(p)],
209
+ key=lambda p: p.stat().st_mtime
210
+ )
211
+ excess = len(ckpts) - max_ckpts
212
+ if excess > 0:
213
+ for p in ckpts[:excess]:
214
+ try:
215
+ p.unlink()
216
+ print(f" [prune] deleted old {p.name}")
217
+ except Exception:
218
+ pass
219
+ except Exception as e:
220
+ print(f"[ckpt-prune] error: {e}")
221
+
222
+ def print_expansion_info(cfg: dict, tie_weights: bool = False):
223
+ d_k = cfg["d"] // cfg["heads"]
224
+ rank = cfg["rank"]
225
+ ratio = rank / d_k
226
+ regime = "COMPRESSION" if ratio < 1 else ("IDENTITY" if ratio == 1 else "EXPANSION")
227
+ tie_str = "YES" if tie_weights else "NO"
228
+ print(f"β”Œβ”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€οΏ½οΏ½οΏ½β”€β”€β”€β”€β”€β”€β”")
229
+ print(f"β”‚ TUNEABLE ATTENTION CONFIG β”‚")
230
+ print(f"β”œβ”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€")
231
+ print(f"β”‚ d_model: {cfg['d']:4d} heads: {cfg['heads']:2d} d_k: {d_k:3d} β”‚")
232
+ print(f"β”‚ layers: {cfg['layers']:4d} tie_weights: {tie_str:3s} β”‚")
233
+ print(f"β”‚ rank: {rank:4d} ratio: {ratio:.1f}x [{regime:11s}] β”‚")
234
+ print(f"β””β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”˜")
235
+
236
+ # ───────────────────────── AMP helper ─────────────────────────
237
+ try:
238
+ from torch.amp import autocast as _ac, GradScaler
239
+ except ImportError:
240
+ from torch.cuda.amp import autocast as _ac, GradScaler
241
+
242
+ def _auto_amp_dtype():
243
+ if DEV.type == "cuda":
244
+ try:
245
+ if torch.cuda.is_bf16_supported(): return torch.bfloat16
246
+ return torch.float16
247
+ except Exception: return torch.float16
248
+ return torch.float32
249
+
250
+ def amp(enabled: bool):
251
+ if not (enabled and DEV.type == "cuda"): return nullcontext()
252
+ try: return _ac(device_type="cuda", dtype=_auto_amp_dtype())
253
+ except TypeError: return _ac(dtype=_auto_amp_dtype())
254
+
255
+ # ───────────────────────── Chat & Data Stream ─────────────────────────
256
+ def _coerce_role(r: str) -> str:
257
+ r = (r or "").lower()
258
+ if r in {"user", "human", "customer"}: return "user"
259
+ if r in {"assistant", "gpt", "bot"}: return "assistant"
260
+ if r in {"system", "context"}: return "system"
261
+ return r or "user"
262
+
263
+ def _render_chat_text_from_ex(ex: dict, messages_key: str, add_generation_prompt: bool) -> Optional[str]:
264
+ msgs = ex.get(messages_key)
265
+ if msgs is None:
266
+ for alt in ("conversations", "dialog", "turns"):
267
+ if isinstance(ex.get(alt), list):
268
+ msgs = ex[alt]; break
269
+ if isinstance(msgs, list) and msgs and isinstance(msgs[0], dict):
270
+ try:
271
+ norm = []
272
+ for m in msgs:
273
+ role = _coerce_role(m.get("role", "")); content = m.get("content", m.get("text", ""))
274
+ if not isinstance(content, str): continue
275
+ norm.append({"role": role, "content": content})
276
+ if not norm: return None
277
+ return tok.apply_chat_template(norm, tokenize=False, add_generation_prompt=add_generation_prompt)
278
+ except Exception: return None
279
+ for a, b in (("prompt", "response"), ("instruction", "output"), ("question", "answer")):
280
+ if isinstance(ex.get(a), str) and isinstance(ex.get(b), str):
281
+ return f"User: {ex[a]}\nAssistant: {ex[b]}"
282
+ return None
283
+
284
+ def _open_stream_one(ds_name: str, seed: int, streaming: bool = True):
285
+ dc = DownloadConfig(max_retries=5, use_etag=True, resume_download=True)
286
+ if ":" in ds_name: base, config = ds_name.split(":", 1)
287
+ else: base, config = ds_name, None
288
+ if not streaming:
289
+ print(f"[download] Downloading {ds_name} (non-streaming)...")
290
+ if base == "json":
291
+ data_files = {"train": config}
292
+ ds = load_dataset("json", data_files=data_files, split="train", streaming=streaming, download_config=dc)
293
+ else:
294
+ ds = load_dataset(base, config, split="train", streaming=streaming, download_config=dc) if config else \
295
+ load_dataset(base, split="train", streaming=streaming, download_config=dc)
296
+ if streaming:
297
+ return iter(ds.shuffle(buffer_size=1000, seed=seed))
298
+ else:
299
+ print(f"[download] Got {len(ds):,} examples. Shuffling...")
300
+ ds = ds.shuffle(seed=seed)
301
+ return iter(ds)
302
+
303
+
304
+ # ─────────────────────────────── HOT DATASET CONFIG ───────────────────────────────
305
+ _HOT_CFG_PATH = pathlib.Path("/workspace/hot_config.json")
306
+ _hot_cache = {"mtime": 0, "data": {}}
307
+
308
+ def get_hot_datasets(default):
309
+ try:
310
+ if _HOT_CFG_PATH.exists():
311
+ mt = _HOT_CFG_PATH.stat().st_mtime
312
+ if mt > _hot_cache["mtime"]:
313
+ _hot_cache["data"] = json.loads(_HOT_CFG_PATH.read_text())
314
+ _hot_cache["mtime"] = mt
315
+ cfg = _hot_cache["data"]
316
+ if "datasets" in cfg:
317
+ ds = cfg["datasets"]
318
+ if isinstance(ds, list): ds = ",".join(ds)
319
+ print(f"[HOT] Using: {ds[:60]}...")
320
+ return ds
321
+ except Exception as e:
322
+ print(f"[HOT] Error: {e}")
323
+ return default
324
+
325
+ def token_stream(ds_names: str, target: int, seed: int = 42,
326
+ chat: bool = False, chat_messages_key: str = "messages",
327
+ sft_add_generation_prompt: bool = False, dataset_field_text: str = "text",
328
+ streaming: bool = True):
329
+ ds_names = get_hot_datasets(ds_names)
330
+ sources = [s.strip() for s in ds_names.split(",") if s.strip()]
331
+ if not sources: return
332
+ src_idx = 0; emitted = 0; it = None; attempts = 0; backoff_base = 2.0
333
+ while emitted < target:
334
+ try:
335
+ if it is None: it = _open_stream_one(sources[src_idx], seed, streaming=streaming)
336
+ ex = next(it)
337
+ text = None
338
+ if isinstance(ex, dict):
339
+ if chat:
340
+ text = _render_chat_text_from_ex(ex, chat_messages_key, sft_add_generation_prompt)
341
+ if text is None:
342
+ if dataset_field_text and isinstance(ex.get(dataset_field_text), str):
343
+ text = ex[dataset_field_text]
344
+ elif isinstance(ex.get("text"), str):
345
+ text = ex["text"]
346
+ if not isinstance(text, str):
347
+ attempts = 0; continue
348
+ enc = tok.encode(text)
349
+ if EOS is not None and (len(enc) == 0 or enc[-1] != EOS):
350
+ enc = enc + [EOS]
351
+ for t in enc:
352
+ yield t
353
+ emitted += 1
354
+ if emitted >= target: return
355
+ attempts = 0
356
+ except StopIteration:
357
+ it = None; src_idx = (src_idx + 1) % len(sources)
358
+ except Exception as e:
359
+ attempts += 1
360
+ sleep_s = min(60.0, backoff_base ** min(attempts, 6))
361
+ print(f"[stream-retry] {sources[src_idx]} error: {type(e).__name__}, sleeping {sleep_s:.1f}s")
362
+ time.sleep(sleep_s); it = None
363
+ if attempts % 2 == 0 and len(sources) > 1:
364
+ src_idx = (src_idx + 1) % len(sources)
365
+
366
+ # ───────────────────────── ALiBi ─────────────────────────
367
+ @torch._dynamo.disable
368
+ def _alibi_slopes(n_heads: int):
369
+ def pow2slopes(n):
370
+ start = 2 ** (-2 ** -(math.log2(n) - 3))
371
+ ratio = start
372
+ return [start * (ratio ** i) for i in range(n)]
373
+ if math.log2(n_heads).is_integer(): vals = pow2slopes(n_heads)
374
+ else:
375
+ closest = 2 ** math.floor(math.log2(n_heads))
376
+ vals = pow2slopes(closest)
377
+ extra = pow2slopes(2 * closest)
378
+ vals += extra[0::2][: n_heads - closest]
379
+ return torch.tensor(vals, device=DEV).view(1, n_heads, 1, 1)
380
+
381
+ @torch._dynamo.disable
382
+ def alibi_bias(n_heads: int, n_tokens: int):
383
+ i = torch.arange(n_tokens, device=DEV).view(1, 1, n_tokens, 1)
384
+ j = torch.arange(n_tokens, device=DEV).view(1, 1, 1, n_tokens)
385
+ dist = (j - i).clamp_min(0)
386
+ return -_alibi_slopes(n_heads) * dist
387
+
388
+ # ───────────────────────── Model components ─────────────────────────
389
+ class TuneableAttentionMHA(nn.Module):
390
+ def __init__(self, d: int, h: int, r: int, use_relpos: bool = True):
391
+ super().__init__()
392
+ assert d % h == 0
393
+ self.h, self.dk, self.r = h, d // h, r
394
+ self.use_relpos = use_relpos
395
+ self.q = nn.Linear(d, d, bias=False)
396
+ self.k = nn.Linear(d, d, bias=False)
397
+ self.v = nn.Linear(d, d, bias=False)
398
+ self.U = nn.Parameter(torch.randn(self.dk, r))
399
+ nn.init.orthogonal_(self.U)
400
+ self.proj = nn.Linear(h * self.dk, d, bias=False)
401
+ self.drop = nn.Dropout(0.1)
402
+
403
+ def _proj_qk(self, x):
404
+ B, N, _ = x.shape
405
+ return (x.view(B, N, self.h, self.dk).transpose(1, 2) @ self.U)
406
+
407
+ def _reshape_v(self, x):
408
+ B, N, _ = x.shape
409
+ return x.view(B, N, self.h, self.dk).transpose(1, 2)
410
+
411
+ def forward(self, x, mask=None, rel_bias_tokens=None, kv_cache=None, use_cache=False):
412
+ q = self._proj_qk(self.q(x))
413
+ k_new = self._proj_qk(self.k(x))
414
+ v_new = self._reshape_v(self.v(x))
415
+ if kv_cache is None:
416
+ k, v = k_new, v_new
417
+ else:
418
+ k_cached, v_cached = kv_cache
419
+ if use_cache:
420
+ k = torch.cat([k_cached, k_new], dim=2)
421
+ v = torch.cat([v_cached, v_new], dim=2)
422
+ else:
423
+ k, v = k_new, v_new
424
+ att = (q @ k.transpose(-1, -2)) / math.sqrt(self.dk)
425
+ if self.use_relpos and rel_bias_tokens is not None:
426
+ att = att + alibi_bias(self.h, rel_bias_tokens).to(att.dtype)[:, :, -q.size(2):, :]
427
+ if mask is not None:
428
+ att = att + mask.to(att.dtype)
429
+ z = (att.softmax(-1) @ v).transpose(1, 2).reshape(x.size(0), x.size(1), -1)
430
+ out = self.drop(self.proj(z))
431
+ return (out, (k, v)) if use_cache else out
432
+
433
+
434
+ class Block(nn.Module):
435
+ def __init__(self, d: int, h: int, r: int):
436
+ super().__init__()
437
+ self.ln1, self.ln2 = nn.LayerNorm(d), nn.LayerNorm(d)
438
+ self.mha = TuneableAttentionMHA(d, h, r)
439
+ self.ff = nn.Sequential(nn.Linear(d, 4 * d), nn.ReLU(), nn.Linear(4 * d, d))
440
+
441
+ def forward(self, x, mask, kv=None, use_cache=False, total_seq_len=None):
442
+ if use_cache:
443
+ y, new_kv = self.mha(self.ln1(x), mask, rel_bias_tokens=total_seq_len, kv_cache=kv, use_cache=True)
444
+ x = x + y + self.ff(self.ln2(x + y))
445
+ return x, new_kv
446
+ else:
447
+ n = x.size(1)
448
+ x = x + self.mha(self.ln1(x), mask, rel_bias_tokens=n)
449
+ return x + self.ff(self.ln2(x))
450
+
451
+
452
+ class Encoder(nn.Module):
453
+ def __init__(self, cfg, tie_weights: bool = False):
454
+ super().__init__()
455
+ d, l, h, r = cfg["d"], cfg["layers"], cfg["heads"], cfg["rank"]
456
+ self.emb = nn.Embedding(VOCAB, d)
457
+ self.blocks = nn.ModuleList([Block(d, h, r) for _ in range(l)])
458
+ self.ln = nn.LayerNorm(d)
459
+ self.tie_weights = tie_weights
460
+
461
+ def forward(self, ids, mask, kv_caches=None, use_cache=False, total_seq_len=None):
462
+ x = self.emb(ids)
463
+ if not use_cache:
464
+ for blk in self.blocks:
465
+ x = blk(x, mask)
466
+ return self.ln(x)
467
+ new_kvs = []
468
+ for i, blk in enumerate(self.blocks):
469
+ kv = kv_caches[i] if kv_caches else None
470
+ x, kv_out = blk(x, mask, kv, use_cache=True, total_seq_len=total_seq_len)
471
+ new_kvs.append(kv_out)
472
+ return self.ln(x), new_kvs
473
+
474
+
475
+ class ARHead(nn.Module):
476
+ def __init__(self, d, tie_weights: bool = False, embedding_weight: nn.Parameter = None):
477
+ super().__init__()
478
+ self.tie_weights = tie_weights
479
+ if tie_weights and embedding_weight is not None:
480
+ self.proj = nn.Linear(d, VOCAB, bias=False)
481
+ self.proj.weight = embedding_weight
482
+ else:
483
+ self.proj = nn.Linear(d, VOCAB)
484
+
485
+ def forward(self, h):
486
+ return self.proj(h)
487
+
488
+
489
+ class SATHead(nn.Module):
490
+ def __init__(self, d, mode="var"):
491
+ super().__init__()
492
+ self.proj = nn.Linear(d, VOCAB)
493
+ self.gate = nn.Linear(d, 2) if mode == "var" else None
494
+ def forward(self, h_last):
495
+ return self.proj(h_last), (self.gate(h_last[:, 0]) if self.gate else None)
496
+
497
+
498
+ # ───────────────────────── Masks ─────────────────────────
499
+ def causal_mask(n):
500
+ return torch.triu(torch.full((1, 1, n, n), float("-inf"), device=DEV), 1)
501
+
502
+ def sat_mask(n, block=SAT_BLOCK):
503
+ idx = torch.arange(n, device=DEV)
504
+ grp = idx.unsqueeze(0) // block
505
+ allow = (grp.T == grp) | (grp.T > grp)
506
+ return torch.where(allow, 0.0, float("-inf")).unsqueeze(0).unsqueeze(0)
507
+
508
+ def sat_mask_cached(new_len: int, cached_len: int, block=SAT_BLOCK):
509
+ total_len = cached_len + new_len
510
+ mask = torch.zeros((1, 1, new_len, total_len), device=DEV)
511
+ return mask
512
+
513
+
514
+ # ───────────────────────── Checkpoint helpers ─────────────────────────
515
+ def save_ckpt(path: pathlib.Path, core, ar_h, sat_h, opt, scaler, meta):
516
+ path.parent.mkdir(exist_ok=True, parents=True)
517
+ tmp = path.with_suffix(path.suffix + ".tmp")
518
+ state = {
519
+ "core": _strip_compiled_prefix(core.state_dict()), "ar": _strip_compiled_prefix(ar_h.state_dict()), "sat": _strip_compiled_prefix(sat_h.state_dict()),
520
+ "opt": opt.state_dict(), "scaler": scaler.state_dict(),
521
+ "cfg": meta.get("cfg"), "tokenizer_id": TOKENIZER_ID,
522
+ "tie_weights": meta.get("tie_weights", False),
523
+ **{k: v for k, v in meta.items() if k not in ("cfg", "tie_weights")}
524
+ }
525
+ torch.save(state, tmp, _use_new_zipfile_serialization=False)
526
+ tmp.replace(path)
527
+ (path.parent / "latest.json").write_text(json.dumps({"path": str(path), "step": meta["step"], "block_size": meta.get("block_size"), "batch_size": meta.get("batch_size"), "seen_tok": meta.get("seen_tok")}))
528
+ print(f"\nβœ“ saved checkpoint {path.name}")
529
+
530
+ def _strip_compiled_prefix(sd):
531
+ return {k.replace("_orig_mod.", ""): v for k, v in sd.items()}
532
+
533
+ def load_ckpt(path, core, ar_h, sat_h, opt, scaler):
534
+ p = _resolve_ckpt(path) or path
535
+ ck = _try_load(p, map_location="cpu")
536
+ if ck is None: raise FileNotFoundError(f"No valid checkpoint at {p}")
537
+ core.load_state_dict(_strip_compiled_prefix(ck["core"]))
538
+ ar_h.load_state_dict(_strip_compiled_prefix(ck["ar"]))
539
+ sat_h.load_state_dict(_strip_compiled_prefix(ck["sat"]))
540
+ try: opt.load_state_dict(ck["opt"])
541
+ except Exception: pass # optimizer state may not match after compile
542
+ if ck.get("scaler"): scaler.load_state_dict(ck["scaler"])
543
+ return ck.get("step", 0), ck.get("seen_tok", 0), ck.get("wall_time", time.time()), ck.get("block_size")
544
+
545
+ def _safe_load_any(path: pathlib.Path, tgt: nn.Module, key: str | None = None):
546
+ p = _resolve_ckpt(path) or path
547
+ if not p.exists(): return 0
548
+ ck = _try_load(p, map_location="cpu")
549
+ if ck is None: return 0
550
+ sd = ck.get(key, ck) if key else ck
551
+ if isinstance(sd, dict) and "state_dict" in sd: sd = sd["state_dict"]
552
+ tgt_sd = tgt.state_dict()
553
+ filt = {k: v for k, v in sd.items() if k in tgt_sd and v.shape == tgt_sd[k].shape}
554
+ if filt: tgt.load_state_dict(filt, strict=False)
555
+ return len(filt)
556
+
557
+ def infer_cfg_from_ckpt(path: pathlib.Path):
558
+ p = _resolve_ckpt(path) or path
559
+ if not p.exists(): return None
560
+ sd = _try_load(p, map_location="cpu")
561
+ if sd is None: return None
562
+ if "cfg" in sd: return dict(sd["cfg"])
563
+ return None
564
+
565
+
566
+ # ───────────────────────── Training Logic ─────────────────────────
567
+ def _parse_grow_plan(s: str) -> List[int]:
568
+ return sorted(set([int(x.strip()) for x in s.split(",") if x.strip() and int(x.strip()) >= 128]))
569
+
570
+ def _count_enabled_params(*modules) -> int:
571
+ seen_data_ptrs = set()
572
+ total = 0
573
+ for m in modules:
574
+ if m is None:
575
+ continue
576
+ for p in m.parameters():
577
+ if p.data_ptr() not in seen_data_ptrs:
578
+ seen_data_ptrs.add(p.data_ptr())
579
+ total += p.numel()
580
+ return total
581
+
582
+ def _phase_freeze(core: nn.Module, *, freeze_core: bool, unfreeze_ln: bool, train_emb: bool):
583
+ for p in core.parameters(): p.requires_grad = not freeze_core
584
+ if freeze_core:
585
+ if unfreeze_ln:
586
+ for blk in core.blocks:
587
+ for p in blk.ln1.parameters(): p.requires_grad = True
588
+ for p in blk.ln2.parameters(): p.requires_grad = True
589
+ for p in core.ln.parameters(): p.requires_grad = True
590
+ if train_emb:
591
+ for p in core.emb.parameters(): p.requires_grad = True
592
+
593
+ def _train_phase(
594
+ args, phase_name: str,
595
+ core, ar_h, sat_h, opt, scaler,
596
+ start_step, seen_tok, resume_wall_time,
597
+ cfg, source, steps, block_size, batch_size,
598
+ chat_cfg: dict,
599
+ max_ckpts: int,
600
+ target_tokens_override: Optional[int] = None,
601
+ tie_weights: bool = False,
602
+ streaming: bool = True
603
+ ):
604
+ BLOCK = block_size
605
+ BATCH = batch_size
606
+ if target_tokens_override is not None:
607
+ target_tokens = target_tokens_override
608
+ else:
609
+ ratio = 51.2 if args.chilla_max_double else 25
610
+ param_count = _count_enabled_params(core, ar_h, sat_h)
611
+ target_tokens = int(ratio * param_count)
612
+ if steps:
613
+ phase_target_tokens = steps * BLOCK * BATCH
614
+ total_tokens_needed = seen_tok + phase_target_tokens
615
+ else:
616
+ total_tokens_needed = target_tokens
617
+ if total_tokens_needed <= seen_tok:
618
+ print(f"[{phase_name}] target {total_tokens_needed} already reached.")
619
+ return start_step, seen_tok, resume_wall_time
620
+ stream = token_stream(
621
+ source, total_tokens_needed, seed=42,
622
+ chat=chat_cfg.get("chat", False),
623
+ chat_messages_key=chat_cfg.get("key", "messages"),
624
+ sft_add_generation_prompt=chat_cfg.get("gen_prompt", False),
625
+ dataset_field_text=chat_cfg.get("text_field", "text"),
626
+ streaming=streaming
627
+ )
628
+ ce_tok = nn.CrossEntropyLoss(label_smoothing=0.1)
629
+ ce_gate = nn.CrossEntropyLoss()
630
+ pbar = SafeProgress(total=total_tokens_needed, initial=seen_tok, unit="tok")
631
+ grow_plan = _parse_grow_plan(args.grow_plan) if args.auto_grow else []
632
+ buf: list[int] = []
633
+ batch_accum: list[list[int]] = []
634
+ step = start_step
635
+ steps_since_last_grow = 0
636
+ oom_retries = 0
637
+ MAX_OOM_RETRIES = 2
638
+ now_wall = time.time()
639
+ last_save_mono = time.monotonic() - (now_wall - (resume_wall_time or now_wall))
640
+ print(f"[{phase_name}] Starting. Goal: {total_tokens_needed:,} tokens. Batch={BATCH}, Block={BLOCK}")
641
+ print(f"[{phase_name}] AR_ONLY={args.ar_only}, TIE_WEIGHTS={tie_weights}, STREAMING={streaming}")
642
+ step_start_time = time.monotonic()
643
+ tok_per_sec_avg = 0.0
644
+ while seen_tok < total_tokens_needed:
645
+ try:
646
+ while len(buf) < BLOCK:
647
+ buf.append(next(stream))
648
+ except StopIteration:
649
+ break
650
+ seq = buf[:BLOCK]
651
+ buf = buf[BLOCK:]
652
+ batch_accum.append(seq)
653
+ if len(batch_accum) < BATCH:
654
+ continue
655
+ ids = torch.tensor(batch_accum, device=DEV)
656
+ batch_accum = []
657
+ tgt_ar = ids.clone()
658
+ try:
659
+ with amp(args.amp):
660
+ h_ar = core(ids, causal_mask(ids.size(1)))
661
+ logits_ar = ar_h(h_ar)[:, :-1]
662
+ loss_ar = ce_tok(logits_ar.reshape(-1, VOCAB), tgt_ar[:, 1:].reshape(-1))
663
+ if args.ar_only:
664
+ loss = loss_ar
665
+ else:
666
+ h_sat = core(ids, sat_mask(ids.size(1)))
667
+ logits_sat, gate = sat_h(h_sat[:, -SAT_BLOCK:])
668
+ tgt_sat = ids[:, 1:SAT_BLOCK+1]
669
+ loss_sat = ce_tok(logits_sat.reshape(-1, VOCAB), tgt_sat.reshape(-1))
670
+ if gate is not None:
671
+ loss_sat += EMIT_LAMBDA * ce_gate(gate, torch.ones(ids.size(0), device=DEV, dtype=torch.long))
672
+ loss = loss_ar + loss_sat
673
+ scaler.scale(loss).backward()
674
+ scaler.unscale_(opt)
675
+ nn.utils.clip_grad_norm_(core.parameters(), 1.0)
676
+ scaler.step(opt)
677
+ scaler.update()
678
+ opt.zero_grad(set_to_none=True)
679
+ except RuntimeError as e:
680
+ msg = str(e).lower()
681
+ if "out of memory" in msg or "cuda error" in msg:
682
+ batch_accum = []
683
+ opt.zero_grad(set_to_none=True)
684
+ if DEV.type == "cuda":
685
+ torch.cuda.empty_cache()
686
+ torch.cuda.synchronize()
687
+ oom_retries += 1
688
+ if oom_retries <= MAX_OOM_RETRIES:
689
+ print(f"\n[{phase_name} OOM] Retry {oom_retries}/{MAX_OOM_RETRIES} at Batch={BATCH}, clearing VRAM...")
690
+ time.sleep(4)
691
+ continue
692
+ oom_retries = 0
693
+ if BATCH > 1:
694
+ print(f"\n[{phase_name} OOM] Reducing Batch: {BATCH} -> {BATCH - 1} (after {MAX_OOM_RETRIES} retries)")
695
+ BATCH -= 1
696
+ time.sleep(4)
697
+ else:
698
+ if grow_plan:
699
+ smaller = [b for b in grow_plan if b < BLOCK]
700
+ new_block = smaller[-1] if smaller else max(128, BLOCK // 2)
701
+ else:
702
+ new_block = max(128, BLOCK // 2)
703
+ print(f"\n[{phase_name} OOM] Reducing Block: {BLOCK} -> {new_block}")
704
+ BLOCK = new_block
705
+ time.sleep(4)
706
+ steps_since_last_grow = 0
707
+ continue
708
+ raise
709
+ step += 1
710
+ oom_retries = 0
711
+ toks_processed = BLOCK * BATCH
712
+ seen_tok += toks_processed
713
+ pbar.update(toks_processed)
714
+ pbar.set_postfix(loss=f"{loss.item():.3f}", B=BATCH, L=BLOCK)
715
+ step_elapsed = time.monotonic() - step_start_time
716
+ tok_per_sec_now = toks_processed / step_elapsed if step_elapsed > 0 else 0
717
+ tok_per_sec_avg = 0.9 * tok_per_sec_avg + 0.1 * tok_per_sec_now if tok_per_sec_avg > 0 else tok_per_sec_now
718
+ step_start_time = time.monotonic()
719
+ write_status(step, seen_tok, loss.item(), BATCH, BLOCK, tok_per_sec_avg, phase_name)
720
+ if args.save_every_sec > 0:
721
+ now_mono = time.monotonic()
722
+ if now_mono - last_save_mono >= args.save_every_sec:
723
+ ck_name = f"{phase_name}_step{step:08d}.pt"
724
+ save_ckpt(pathlib.Path(args.save_dir) / ck_name, core, ar_h, sat_h, opt, scaler,
725
+ meta={"cfg": cfg, "step": step, "seen_tok": seen_tok, "wall_time": time.time(), "tie_weights": tie_weights, "block_size": BLOCK, "batch_size": BATCH})
726
+ _prune_checkpoints(pathlib.Path(args.save_dir), phase_name, max_ckpts)
727
+ last_save_mono = now_mono
728
+ if args.auto_grow:
729
+ steps_since_last_grow += 1
730
+ if steps_since_last_grow >= args.grow_every_steps:
731
+ steps_since_last_grow = 0
732
+ try:
733
+ idx = grow_plan.index(BLOCK)
734
+ if idx + 1 < len(grow_plan):
735
+ BLOCK = grow_plan[idx + 1]
736
+ print(f"[{phase_name} Grow] Block -> {BLOCK}")
737
+ if DEV.type == "cuda": torch.cuda.empty_cache()
738
+ except ValueError:
739
+ grow_plan = sorted(set(grow_plan + [BLOCK]))
740
+ pbar.close()
741
+ save_ckpt(pathlib.Path(args.save_dir) / f"{phase_name}_final.pt", core, ar_h, sat_h, opt, scaler,
742
+ meta={"cfg": cfg, "step": step, "seen_tok": seen_tok, "wall_time": time.time(), "tie_weights": tie_weights, "block_size": BLOCK, "batch_size": BATCH})
743
+ return step, seen_tok, time.time()
744
+
745
+
746
+ # ───────────────────────── Main Orchestrator ─────────────────────────
747
+ def train(args):
748
+ cfg = PRESETS[args.preset].copy()
749
+ tie_weights = args.tie_weights
750
+ print_expansion_info(cfg, tie_weights)
751
+ if not args.fresh:
752
+ src_probe = pathlib.Path(args.warmstart_from) if args.warmstart_from else pathlib.Path(args.save_dir) / "final.pt"
753
+ prev_cfg = infer_cfg_from_ckpt(src_probe)
754
+ else: prev_cfg = None
755
+ if prev_cfg:
756
+ cfg.update({k: v for k, v in prev_cfg.items() if k in cfg})
757
+ if args.x2 and prev_cfg.get("layers"): cfg["layers"] = max(cfg["layers"], prev_cfg["layers"] * 2)
758
+ if args.rank: cfg["rank"] = args.rank
759
+ if args.x2 and not prev_cfg: cfg["layers"] *= 2
760
+ print(f"Config: {cfg}")
761
+ core = Encoder(cfg, tie_weights=tie_weights).to(DEV)
762
+ ar_h = ARHead(cfg["d"], tie_weights=tie_weights, embedding_weight=core.emb.weight if tie_weights else None).to(DEV)
763
+ sat_h = SATHead(cfg["d"], mode="var").to(DEV)
764
+ total_params = _count_enabled_params(core, ar_h, sat_h)
765
+ print(f"Total parameters: {total_params:,}")
766
+ if tie_weights:
767
+ print(f"{Colors.WARN}[weight-tying] Embedding and LM head share weights{Colors.RESET}")
768
+ if not args.fresh:
769
+ src = pathlib.Path(args.warmstart_from) if args.warmstart_from else pathlib.Path(args.save_dir) / "final.pt"
770
+ src = _resolve_ckpt(src)
771
+ if src:
772
+ loaded = _safe_load_any(src, core, key="core")
773
+ _safe_load_any(src, ar_h, key="ar")
774
+ _safe_load_any(src, sat_h, key="sat")
775
+ if loaded: print(f"Warm-start loaded from {src}")
776
+ _phase_freeze(core, freeze_core=args.freeze_core, unfreeze_ln=args.unfreeze_ln, train_emb=args.train_emb)
777
+ opt = torch.optim.AdamW([
778
+ {"params": [p for p in core.parameters() if p.requires_grad], "lr": args.lr_core},
779
+ {"params": ar_h.parameters(), "lr": args.lr_head},
780
+ {"params": sat_h.parameters(), "lr": args.lr_head},
781
+ ])
782
+ scaler = GradScaler(enabled=(args.amp and DEV.type == "cuda"))
783
+ start_step, seen_tok, last_wall, _resumed_block = 0, 0, None, None
784
+ if args.resume and not args.fresh:
785
+ start_step, seen_tok, last_wall, _resumed_block = load_ckpt(pathlib.Path(args.resume), core, ar_h, sat_h, opt, scaler)
786
+ print(f"Resumed from step {start_step}" + (f", block_size={_resumed_block}" if _resumed_block else ""))
787
+ # torch.compile AFTER loading checkpoint (key names differ)
788
+ if args.compile:
789
+ print("[torch.compile] Compiling model...")
790
+ core = torch.compile(core, mode="reduce-overhead")
791
+ ar_h = torch.compile(ar_h, mode="reduce-overhead")
792
+ sat_h = torch.compile(sat_h, mode="reduce-overhead")
793
+ print("[torch.compile] Done.")
794
+ step, seen_tok, last_wall = _train_phase(
795
+ args, "pretrain", core, ar_h, sat_h, opt, scaler,
796
+ start_step, seen_tok, last_wall, cfg,
797
+ args.source, args.steps,
798
+ (_resumed_block if _resumed_block and args.auto_grow else None) or args.block or DEFAULT_BLOCK,
799
+ args.batch_size or DEFAULT_BATCH,
800
+ chat_cfg={"chat": args.chat, "key": args.chat_messages_key, "gen_prompt": args.sft_add_generation_prompt, "text_field": args.dataset_field_text},
801
+ max_ckpts=args.max_ckpts,
802
+ target_tokens_override=args.target_tokens,
803
+ tie_weights=tie_weights
804
+ )
805
+ if (not args.after_sft_source) and (args.after_sft_steps and args.after_sft_steps > 0):
806
+ args.after_sft_source = DEFAULT_AFTER_SFT_SOURCES
807
+ args.after_sft_chat = True
808
+ if args.after_sft_add_generation_prompt is None: args.after_sft_add_generation_prompt = True
809
+ if not args.after_sft_block: args.after_sft_block = DEFAULT_AFTER_SFT_BLOCK
810
+ if args.after_sft_source and args.after_sft_steps and args.after_sft_steps > 0:
811
+ print("\n[Orchestrator] Starting Post-Pretraining SFT Phase...")
812
+ _phase_freeze(core,
813
+ freeze_core=args.after_sft_freeze_core,
814
+ unfreeze_ln=args.after_sft_unfreeze_ln,
815
+ train_emb=args.after_sft_train_emb)
816
+ opt = torch.optim.AdamW([
817
+ {"params": [p for p in core.parameters() if p.requires_grad], "lr": args.after_sft_lr_core or args.lr_core},
818
+ {"params": ar_h.parameters(), "lr": args.after_sft_lr_head or args.lr_head},
819
+ {"params": sat_h.parameters(), "lr": args.after_sft_lr_head or args.lr_head},
820
+ ])
821
+ step, seen_tok, last_wall = _train_phase(
822
+ args, "sft", core, ar_h, sat_h, opt, scaler,
823
+ step, seen_tok, last_wall, cfg,
824
+ args.after_sft_source, args.after_sft_steps,
825
+ args.after_sft_block or DEFAULT_AFTER_SFT_BLOCK,
826
+ args.batch_size or DEFAULT_BATCH,
827
+ chat_cfg={
828
+ "chat": args.after_sft_chat,
829
+ "key": args.after_sft_chat_messages_key,
830
+ "gen_prompt": args.after_sft_add_generation_prompt if args.after_sft_add_generation_prompt is not None else args.sft_add_generation_prompt,
831
+ "text_field": args.after_sft_dataset_field_text
832
+ },
833
+ max_ckpts=args.max_ckpts,
834
+ target_tokens_override=None,
835
+ tie_weights=tie_weights,
836
+ streaming=False
837
+ )
838
+ save_ckpt(pathlib.Path(args.save_dir) / "final.pt", core, ar_h, sat_h, opt, scaler,
839
+ meta={"cfg": cfg, "step": step, "seen_tok": seen_tok, "wall_time": time.time(), "tie_weights": tie_weights, "block_size": args.block or DEFAULT_BLOCK, "batch_size": args.batch_size or DEFAULT_BATCH})
840
+ print("πŸŽ‰ All Training Complete")
841
+
842
+
843
+ # ───────────────────────── Sampling ─────────────────────────
844
+ def _apply_penalties(logits, ids, n, rep_p, pres_p, freq_p):
845
+ if ids.numel() == 0: return logits
846
+ hist = ids[0, -n:].long() if n > 0 else ids[0].long()
847
+ uniq, counts = torch.unique(hist, return_counts=True)
848
+ if pres_p or freq_p:
849
+ logits[..., uniq] -= (pres_p + freq_p * counts.to(logits.dtype))
850
+ if rep_p != 1.0:
851
+ sel = logits[..., uniq]
852
+ logits[..., uniq] = torch.where(sel > 0, sel / rep_p, sel * rep_p)
853
+ return logits
854
+
855
+ def _sample(logits, T, top_k, top_p, min_p, greedy):
856
+ if greedy: return logits.argmax(-1, keepdim=True)
857
+ probs = (logits / max(T, 1e-8)).softmax(-1)
858
+ if top_k:
859
+ v, i = torch.topk(probs, min(top_k, probs.size(-1)))
860
+ probs = torch.zeros_like(probs).scatter_(-1, i, v)
861
+ if top_p < 1.0:
862
+ s_probs, s_idx = torch.sort(probs, descending=True, dim=-1)
863
+ probs = torch.zeros_like(probs).scatter_(-1, s_idx, s_probs * (torch.cumsum(s_probs, -1) <= top_p).to(probs.dtype))
864
+ if min_p > 0: probs[probs < min_p] = 0
865
+ if probs.sum() == 0: return logits.argmax(-1, keepdim=True)
866
+ return probs.div_(probs.sum()).multinomial(1)
867
+
868
+ @torch.no_grad()
869
+ def infer(args):
870
+ if args.mode == "ar":
871
+ if args.temperature is None: args.temperature = 0.7
872
+ if args.top_k is None: args.top_k = 0
873
+ if args.repetition_penalty is None: args.repetition_penalty = 1.3
874
+ if args.presence_penalty is None: args.presence_penalty = 0.0
875
+ if args.frequency_penalty is None: args.frequency_penalty = 0.3
876
+ if args.penalty_last_n is None: args.penalty_last_n = 128
877
+ if args.var is None: args.var = False
878
+ else:
879
+ if args.temperature is None: args.temperature = 0.5
880
+ if args.top_k is None: args.top_k = 30
881
+ if args.repetition_penalty is None: args.repetition_penalty = 2.0
882
+ if args.presence_penalty is None: args.presence_penalty = 0.6
883
+ if args.frequency_penalty is None: args.frequency_penalty = 1.0
884
+ if args.penalty_last_n is None: args.penalty_last_n = 200
885
+ if args.var is None: args.var = True
886
+ path = _resolve_ckpt(pathlib.Path(args.ckpt)) or pathlib.Path(args.ckpt)
887
+ sd = torch.load(path, map_location="cpu")
888
+ cfg = sd["cfg"]
889
+ tie_weights = sd.get("tie_weights", False)
890
+ uk_time = get_uk_time()
891
+ ckpt_name = path.name
892
+ print(f"β”Œβ”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”")
893
+ print(f"β”‚ INFERENCE @ {uk_time:<35s} β”‚")
894
+ print(f"β”œβ”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€")
895
+ print(f"β”‚ Checkpoint: {ckpt_name:<35s} β”‚")
896
+ print(f"β””β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”˜")
897
+ print_expansion_info(cfg, tie_weights)
898
+ _use_fp16 = getattr(args, 'fp16', False)
899
+ core = Encoder(cfg, tie_weights=tie_weights)
900
+ ar_h = ARHead(cfg["d"], tie_weights=tie_weights, embedding_weight=core.emb.weight if tie_weights else None)
901
+ sat_h = SATHead(cfg["d"])
902
+ core.load_state_dict(sd["core"])
903
+ ar_h.load_state_dict(sd["ar"])
904
+ sat_h.load_state_dict(sd["sat"])
905
+ if _use_fp16:
906
+ core.half(); ar_h.half(); sat_h.half()
907
+ print(f"{Colors.INFO}Using fp16 inference{Colors.RESET}")
908
+ core.to(DEV).eval()
909
+ ar_h.to(DEV).eval()
910
+ sat_h.to(DEV).eval()
911
+ total_params = _count_enabled_params(core, ar_h, sat_h)
912
+ if total_params >= 1_000_000_000:
913
+ param_str = f"{total_params / 1_000_000_000:.2f}B"
914
+ elif total_params >= 1_000_000:
915
+ param_str = f"{total_params / 1_000_000:.2f}M"
916
+ elif total_params >= 1_000:
917
+ param_str = f"{total_params / 1_000:.2f}K"
918
+ else:
919
+ param_str = f"{total_params}"
920
+ print(f"Model size: {param_str} parameters ({total_params:,})")
921
+ prompt_tokens = tok.encode(args.prompt)
922
+ prompt_len = len(prompt_tokens)
923
+ ids = torch.tensor([prompt_tokens], device=DEV)
924
+ if ids.size(1) == 0:
925
+ ids = torch.tensor([[EOS]], device=DEV)
926
+ prompt_len = 1
927
+ mode_str = args.mode
928
+ if args.mode == "sat":
929
+ mode_str = f"sat-{'var' if args.var else 'fixed'}"
930
+ print(f"{Colors.INFO}Generating ({mode_str})...{Colors.RESET}")
931
+ start = time.time()
932
+ if args.mode == "ar":
933
+ h, kvs = core(ids, causal_mask(ids.size(1)), use_cache=True, total_seq_len=ids.size(1))
934
+ for _ in range(args.max_new):
935
+ logits = ar_h(h)[:, -1]
936
+ logits = _apply_penalties(logits, ids, args.penalty_last_n, args.repetition_penalty, args.presence_penalty, args.frequency_penalty)
937
+ nxt = _sample(logits, args.temperature, args.top_k, args.top_p, args.min_p, args.greedy)
938
+ ids = torch.cat([ids, nxt], 1)
939
+ h, kvs = core(ids[:, -1:], None, kv_caches=kvs, use_cache=True, total_seq_len=ids.size(1))
940
+ else:
941
+ cached_len = ids.size(1)
942
+ h, kvs = core(ids, sat_mask(ids.size(1)), use_cache=True, total_seq_len=cached_len)
943
+ added = 0
944
+ while added < args.max_new:
945
+ logits_all, gate = sat_h(h[:, -SAT_BLOCK:])
946
+ stride = SAT_BLOCK if (not args.var or gate is None) else (gate.softmax(-1).multinomial(1).item() + 1)
947
+ new_tokens = []
948
+ for i in range(int(stride)):
949
+ logits = logits_all[:, i]
950
+ logits = _apply_penalties(logits, ids, args.penalty_last_n, args.repetition_penalty, args.presence_penalty, args.frequency_penalty)
951
+ nxt = _sample(logits, args.temperature, args.top_k, args.top_p, args.min_p, args.greedy)
952
+ new_tokens.append(nxt)
953
+ ids = torch.cat([ids, nxt], 1)
954
+ added += 1
955
+ if added >= args.max_new: break
956
+ if added >= args.max_new: break
957
+ new_ids = torch.cat(new_tokens, dim=1)
958
+ mask = sat_mask_cached(new_ids.size(1), cached_len)
959
+ h, kvs = core(new_ids, mask, kv_caches=kvs, use_cache=True, total_seq_len=ids.size(1))
960
+ cached_len = ids.size(1)
961
+ elapsed = time.time() - start
962
+ gen_tokens = len(ids[0]) - prompt_len
963
+ tok_per_sec = gen_tokens / elapsed if elapsed > 0 else 0
964
+ all_tokens = ids[0].tolist()
965
+ prompt_text = tok.decode(all_tokens[:prompt_len], skip_special_tokens=True)
966
+ gen_text = tok.decode(all_tokens[prompt_len:], skip_special_tokens=True)
967
+ print(f"{Colors.PROMPT}{prompt_text}{Colors.RESET}{gen_text}")
968
+ print(f"{Colors.INFO}[{elapsed:.2f}s | {gen_tokens} tokens | {tok_per_sec:.1f} tok/s]{Colors.RESET}")
969
+
970
+
971
+ # ───────────────────────── CLI ─────────────────────────
972
+ def main():
973
+ ap = argparse.ArgumentParser(description="AGILLM Expansion Ratio Testing")
974
+ sub = ap.add_subparsers(dest="cmd", required=True)
975
+ tr = sub.add_parser("train")
976
+ tr.add_argument("--preset", choices=PRESETS.keys(), default="nano_3x")
977
+ tr.add_argument("--rank", type=int)
978
+ tr.add_argument("--block", type=int, default=DEFAULT_BLOCK)
979
+ tr.add_argument("--batch_size", type=int, default=DEFAULT_BATCH)
980
+ tr.add_argument("--source", default=DEFAULT_PRETRAIN_SOURCES)
981
+ tr.add_argument("--target_tokens", type=int)
982
+ tr.add_argument("--steps", type=int)
983
+ tr.add_argument("--amp", action="store_true")
984
+ tr.add_argument("--compile", action="store_true", help="Use torch.compile for speedup")
985
+ tr.add_argument("--save_every_sec", type=int, default=DEFAULT_SAVE_SEC)
986
+ tr.add_argument("--save_dir", default=str(CKDIR))
987
+ tr.add_argument("--resume", type=str)
988
+ tr.add_argument("--x2", action="store_true")
989
+ tr.add_argument("--warmstart_from", type=str)
990
+ tr.add_argument("--fresh", action="store_true")
991
+ tr.add_argument("--max_ckpts", type=int, default=None)
992
+ tr.add_argument("--chilla_max_double", action="store_true")
993
+ tr.add_argument("--tie_weights", action="store_true")
994
+ tr.add_argument("--ar_only", action="store_true")
995
+ tr.add_argument("--freeze_core", action="store_true")
996
+ tr.add_argument("--unfreeze_ln", action="store_true")
997
+ tr.add_argument("--train_emb", action="store_true")
998
+ tr.add_argument("--lr_core", type=float, default=LR_CORE)
999
+ tr.add_argument("--lr_head", type=float, default=LR_HEAD)
1000
+ tr.add_argument("--chat", action="store_true")
1001
+ tr.add_argument("--chat_messages_key", default="messages")
1002
+ tr.add_argument("--dataset_field_text", default="text")
1003
+ tr.add_argument("--sft_add_generation_prompt", action="store_true")
1004
+ tr.add_argument("--auto_grow", action="store_true")
1005
+ tr.add_argument("--grow_plan", default="576,640,768,896,1024,1122")
1006
+ tr.add_argument("--grow_every_steps", type=int, default=50000)
1007
+ tr.add_argument("--after_sft_source", default="")
1008
+ tr.add_argument("--after_sft_steps", type=int, default=0)
1009
+ tr.add_argument("--after_sft_chat", action="store_true")
1010
+ tr.add_argument("--after_sft_chat_messages_key", default="messages")
1011
+ tr.add_argument("--after_sft_dataset_field_text", default="text")
1012
+ tr.add_argument("--after_sft_add_generation_prompt", type=bool, default=None)
1013
+ tr.add_argument("--after_sft_block", type=int, default=0)
1014
+ tr.add_argument("--after_sft_freeze_core", action="store_true")
1015
+ tr.add_argument("--after_sft_unfreeze_ln", action="store_true")
1016
+ tr.add_argument("--after_sft_train_emb", action="store_true")
1017
+ tr.add_argument("--after_sft_lr_core", type=float, default=0.0)
1018
+ tr.add_argument("--after_sft_lr_head", type=float, default=0.0)
1019
+ inf = sub.add_parser("infer")
1020
+ inf.add_argument("--mode", choices=["ar", "sat"], required=True)
1021
+ inf.add_argument("--ckpt", required=True)
1022
+ inf.add_argument("--prompt", required=True)
1023
+ inf.add_argument("--max_new", type=int, default=120)
1024
+ inf.add_argument("--temperature", type=float, default=None)
1025
+ inf.add_argument("--greedy", action="store_true")
1026
+ inf.add_argument("--top_k", type=int, default=None)
1027
+ inf.add_argument("--top_p", type=float, default=0.9)
1028
+ inf.add_argument("--min_p", type=float, default=0.0)
1029
+ inf.add_argument("--repetition_penalty", type=float, default=None)
1030
+ inf.add_argument("--presence_penalty", type=float, default=None)
1031
+ inf.add_argument("--frequency_penalty", type=float, default=None)
1032
+ inf.add_argument("--penalty_last_n", type=int, default=None)
1033
+ inf.add_argument("--var", action="store_true", default=None)
1034
+ inf.add_argument("--no-var", dest="var", action="store_false")
1035
+ inf.add_argument("--fp16", action="store_true", help="Use fp16 inference (faster, lower VRAM)")
1036
+ st = sub.add_parser("status")
1037
+ args = ap.parse_args()
1038
+ if args.cmd == "train": train(args)
1039
+ elif args.cmd == "status": show_status()
1040
+ else: infer(args)
1041
+
1042
+
1043
+ if __name__ == "__main__":
1044
+ main()