V6.5-7ds cleanup: remove legacy scripts/train_fast.py
Browse files- scripts/train_fast.py +0 -165
scripts/train_fast.py
DELETED
|
@@ -1,165 +0,0 @@
|
|
| 1 |
-
#!/usr/bin/env python3
|
| 2 |
-
"""train_fast.py — Treino rápido de bug-detection (2 épocas, modelo pequeno).
|
| 3 |
-
|
| 4 |
-
Versão otimizada para rodar em < 5 minutos no ambiente Xeon 2-core:
|
| 5 |
-
- max_modules=4 (em vez de 8)
|
| 6 |
-
- bigru_hidden=16 (em vez de 32)
|
| 7 |
-
- d_transformer=32 (em vez de 64)
|
| 8 |
-
- num_layers_train=1, num_layers_hyp=1
|
| 9 |
-
- max_samples=8 por dataset
|
| 10 |
-
- 1 dataset (CEIA-POSITIVO/ultrachat_br_clustred_balanced_v1)
|
| 11 |
-
|
| 12 |
-
Valida todos os 4 lemas sem pretender produzir modelo SOTA.
|
| 13 |
-
"""
|
| 14 |
-
from __future__ import annotations
|
| 15 |
-
|
| 16 |
-
import os
|
| 17 |
-
import sys
|
| 18 |
-
import time
|
| 19 |
-
import json
|
| 20 |
-
import logging
|
| 21 |
-
from pathlib import Path
|
| 22 |
-
|
| 23 |
-
# Adiciona src/ ao path
|
| 24 |
-
sys.path.insert(0, str(Path(__file__).parent.parent / "src"))
|
| 25 |
-
|
| 26 |
-
# Otimização Xeon
|
| 27 |
-
os.environ.setdefault("OMP_NUM_THREADS", "2")
|
| 28 |
-
os.environ.setdefault("MKL_NUM_THREADS", "2")
|
| 29 |
-
os.environ.setdefault("TOKENIZERS_PARALLELISM", "false")
|
| 30 |
-
|
| 31 |
-
import torch
|
| 32 |
-
torch.set_num_threads(2)
|
| 33 |
-
|
| 34 |
-
try:
|
| 35 |
-
from bigru_t.utils.xeon_runtime import optimize_xeon_environment
|
| 36 |
-
optimize_xeon_environment()
|
| 37 |
-
except Exception as e:
|
| 38 |
-
logging.warning(f"Could not apply Xeon optimization: {e}")
|
| 39 |
-
|
| 40 |
-
from bigru_t import (
|
| 41 |
-
UnifiedModel, UnifiedModelConfig, create_unified_model,
|
| 42 |
-
BiGRU_T_Trainer, TrainerConfig,
|
| 43 |
-
)
|
| 44 |
-
from bigru_t.data.streaming_datasets import stream_dataset
|
| 45 |
-
|
| 46 |
-
logging.basicConfig(
|
| 47 |
-
level=logging.INFO,
|
| 48 |
-
format="%(asctime)s [%(levelname)s] %(message)s",
|
| 49 |
-
datefmt="%H:%M:%S",
|
| 50 |
-
handlers=[logging.StreamHandler()],
|
| 51 |
-
)
|
| 52 |
-
logger = logging.getLogger(__name__)
|
| 53 |
-
|
| 54 |
-
|
| 55 |
-
def main():
|
| 56 |
-
# HF token
|
| 57 |
-
hf_token = os.environ.get("HF_TOKEN") or None
|
| 58 |
-
|
| 59 |
-
# Modelo pequeno para bug-detection rápido
|
| 60 |
-
model_config = UnifiedModelConfig(
|
| 61 |
-
vocab_size=16384,
|
| 62 |
-
d_model=64,
|
| 63 |
-
max_seq_len=32,
|
| 64 |
-
pad_token_id=1,
|
| 65 |
-
max_modules=4, # 4 módulos em vez de 8
|
| 66 |
-
bigru_hidden=16, # 16 em vez de 32
|
| 67 |
-
d_transformer=32, # 32 em vez de 64
|
| 68 |
-
nhead_tu=2, # 2 em vez de 4 (32/2=16 ok)
|
| 69 |
-
d_ff_tu=64, # 64 em vez de 128
|
| 70 |
-
output_dim_u8cell=32, # 32 em vez de 64
|
| 71 |
-
cache_len=8, # 8 em vez de 16
|
| 72 |
-
d_cache=64, # 64 em vez de 128
|
| 73 |
-
nhead_orq=2, # 2 em vez de 8 (64/2=32 ok)
|
| 74 |
-
d_ff_orq=128, # 128 em vez de 256
|
| 75 |
-
trainT_dim=64,
|
| 76 |
-
nhead_train=2,
|
| 77 |
-
d_ff_train=128,
|
| 78 |
-
num_layers_train=1, # 1 em vez de 2
|
| 79 |
-
hypT_dim=64,
|
| 80 |
-
nhead_hyp=2,
|
| 81 |
-
d_ff_hyp=128,
|
| 82 |
-
num_layers_hyp=1, # 1 em vez de 2
|
| 83 |
-
num_bits=8,
|
| 84 |
-
dropout=0.1,
|
| 85 |
-
)
|
| 86 |
-
|
| 87 |
-
logger.info("Criando UnifiedModel (small config)...")
|
| 88 |
-
model, _ = create_unified_model(model_config)
|
| 89 |
-
params = model.count_parameters()
|
| 90 |
-
logger.info(f" params: {params['total']:,} ({params['total_M']:.2f}M)")
|
| 91 |
-
|
| 92 |
-
# Tokenizer
|
| 93 |
-
from tokenizers import Tokenizer
|
| 94 |
-
tok_path = "/home/z/my-project/source/model_final/tokenizer/tokenizer.json"
|
| 95 |
-
tokenizer = Tokenizer.from_file(tok_path)
|
| 96 |
-
|
| 97 |
-
# Carrega 1 dataset
|
| 98 |
-
ds_name = "CEIA-POSITIVO/ultrachat_br_clustred_balanced_v1"
|
| 99 |
-
max_samples = 8
|
| 100 |
-
logger.info(f"Loading {max_samples} samples from {ds_name}...")
|
| 101 |
-
samples = []
|
| 102 |
-
t0 = time.time()
|
| 103 |
-
for sample in stream_dataset(ds_name, max_samples=max_samples, hf_token=hf_token):
|
| 104 |
-
samples.append(sample)
|
| 105 |
-
if len(samples) >= max_samples:
|
| 106 |
-
break
|
| 107 |
-
if time.time() - t0 > 120:
|
| 108 |
-
logger.warning(f"Timeout após {len(samples)} amostras")
|
| 109 |
-
break
|
| 110 |
-
logger.info(f"Loaded {len(samples)} samples in {time.time()-t0:.1f}s")
|
| 111 |
-
|
| 112 |
-
if not samples:
|
| 113 |
-
logger.error("Nenhuma amostra carregada")
|
| 114 |
-
sys.exit(1)
|
| 115 |
-
|
| 116 |
-
# Split 90/10
|
| 117 |
-
import random
|
| 118 |
-
random.seed(42)
|
| 119 |
-
random.shuffle(samples)
|
| 120 |
-
split = max(1, int(0.9 * len(samples)))
|
| 121 |
-
train_samples = samples[:split]
|
| 122 |
-
val_samples = samples[split:] or samples[:1]
|
| 123 |
-
logger.info(f" train: {len(train_samples)} | val: {len(val_samples)}")
|
| 124 |
-
|
| 125 |
-
# Trainer config
|
| 126 |
-
trainer_config = TrainerConfig(
|
| 127 |
-
epochs=2,
|
| 128 |
-
datasets=ds_name,
|
| 129 |
-
max_samples_per_dataset=max_samples,
|
| 130 |
-
max_seq_len=32,
|
| 131 |
-
per_device_batch_size=1,
|
| 132 |
-
grad_accum=2,
|
| 133 |
-
lr=1e-3,
|
| 134 |
-
use_hypothesis=True,
|
| 135 |
-
meta_interval=5,
|
| 136 |
-
log_every=1,
|
| 137 |
-
save_temp_every=100, # não salvar temp (modelo pequeno)
|
| 138 |
-
output_dir="/home/z/my-project/BiGRU_T_version/model_final",
|
| 139 |
-
temp_dir="/home/z/my-project/BiGRU_T_version/_temp_checkpoints",
|
| 140 |
-
keep_temp=False,
|
| 141 |
-
)
|
| 142 |
-
|
| 143 |
-
trainer = BiGRU_T_Trainer(
|
| 144 |
-
model=model,
|
| 145 |
-
tokenizer=tokenizer,
|
| 146 |
-
config=trainer_config,
|
| 147 |
-
train_samples=train_samples,
|
| 148 |
-
val_samples=val_samples,
|
| 149 |
-
)
|
| 150 |
-
|
| 151 |
-
result = trainer.train()
|
| 152 |
-
|
| 153 |
-
print("\n=== Resultado Final ===")
|
| 154 |
-
print(json.dumps(result, indent=2, default=str))
|
| 155 |
-
|
| 156 |
-
# Apaga HF token
|
| 157 |
-
if "HF_TOKEN" in os.environ:
|
| 158 |
-
del os.environ["HF_TOKEN"]
|
| 159 |
-
logger.info("HF_TOKEN apagado do ambiente")
|
| 160 |
-
|
| 161 |
-
sys.exit(0 if not result.get("killed") else 1)
|
| 162 |
-
|
| 163 |
-
|
| 164 |
-
if __name__ == "__main__":
|
| 165 |
-
main()
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|