Views
No views yet

llm-jp/llm-jp-3-13b + llm-jp-3-13b-it_lora)を用いて入力データ(elyza-tasks-100-TV_0.jsonl)を推論し、その結果を{new_model_id}-outputs.jsonlというファイルに出力できます。1!pip uninstall unsloth -y
2!pip install --upgrade --no-cache-dir "unsloth[colab-new] @ git+https://github.com/unslothai/unsloth.git"
3!pip install --upgrade torch
4!pip install --upgrade xformers
5
6# Install Flash Attention 2 for softcapping support
7import torch
8if torch.cuda.get_device_capability()[0] >= 8:
9 !pip install --no-deps packaging ninja einops "flash-attn>=2.6.3"
10 1from google.colab import userdata
2HF_TOKEN = userdata.get('HF_TOKEN')1from unsloth import FastLanguageModel
2import torch
3max_seq_length = 512 # unslothではRoPEをサポートしているのでコンテキスト長は自由に設定可能
4dtype = None # Noneにしておけば自動で設定
5load_in_4bit = True # 今回は13Bモデルを扱うためTrue
6
7model_id = "llm-jp/llm-jp-3-13b"
8new_model_id = "llm-jp-3-13b-it"
9
10# FastLanguageModel インスタンスを作成
11model, tokenizer = FastLanguageModel.from_pretrained(
12 model_name=model_id,
13 dtype=dtype,
14 load_in_4bit=load_in_4bit,
15 trust_remote_code=True,
16)
17
18# SFT用のモデルを用意
19model = FastLanguageModel.get_peft_model(
20 model,
21 r = 32,
22 target_modules = ["q_proj", "k_proj", "v_proj", "o_proj",
23 "gate_proj", "up_proj", "down_proj",],
24 lora_alpha = 32,
25 lora_dropout = 0.05,
26 bias = "none",
27 use_gradient_checkpointing = "unsloth",
28 random_state = 3407,
29 use_rslora = False,
30 loftq_config = None,
31 max_seq_length = max_seq_length,
32)
33
34## 入力データの準備
35
36`./elyza-tasks-100-TV_0.jsonl`というファイルからデータセットをロードします。
37
38```python
39from datasets import load_dataset
40
41dataset = load_dataset("json", data_files="/content/drive/MyDrive/ichikara-instruction-003-001-1.json")
42
43# 学習時のプロンプトフォーマットの定義
44prompt = """### 指示
45{}
46### 回答
47{}"""
48
49
50"""
51formatting_prompts_func: 各データをプロンプトに合わせた形式に合わせる
52"""
53EOS_TOKEN = tokenizer.eos_token # トークナイザーのEOSトークン(文末トークン)
54def formatting_prompts_func(examples):
55 input = examples["text"] # 入力データ
56 output = examples["output"] # 出力データ
57 text = prompt.format(input, output) + EOS_TOKEN # プロンプトの作成
58 return { "formatted_text" : text, } # 新しいフィールド "formatted_text" を返す
59pass
60
61# # 各データにフォーマットを適用
62dataset = dataset.map(
63 formatting_prompts_func,
64 num_proc= 4, # 並列処理数を指定
65)
661from trl import SFTTrainer
2from transformers import TrainingArguments
3from unsloth import is_bfloat16_supported
4
5trainer = SFTTrainer(
6 model = model,
7 tokenizer = tokenizer,
8 train_dataset=dataset["train"],
9 max_seq_length = max_seq_length,
10 dataset_text_field="formatted_text",
11 packing = False,
12 args = TrainingArguments(
13 per_device_train_batch_size = 2,
14 gradient_accumulation_steps = 4,
15 num_train_epochs = 1,
16 logging_steps = 10,
17 warmup_steps = 10,
18 save_steps=100,
19 save_total_limit=2,
20 max_steps=-1,
21 learning_rate = 2e-4,
22 fp16 = not is_bfloat16_supported(),
23 bf16 = is_bfloat16_supported(),
24 group_by_length=True,
25 seed = 3407,
26 output_dir = "outputs",
27 report_to = "none",
28 ),
29)
30
31#@title 現在のメモリ使用量を表示
32gpu_stats = torch.cuda.get_device_properties(0)
33start_gpu_memory = round(torch.cuda.max_memory_reserved() / 1024 / 1024 / 1024, 3)
34max_memory = round(gpu_stats.total_memory / 1024 / 1024 / 1024, 3)
35print(f"GPU = {gpu_stats.name}. Max memory = {max_memory} GB.")
36print(f"{start_gpu_memory} GB of memory reserved.")
37
38trainer_stats = trainer.train()
39
40
41# ELYZA-tasks-100-TVの読み込み。事前にファイルをアップロードしてください
42# データセットの読み込み。
43import json
44datasets = []
45with open("/content/drive/MyDrive/elyza-tasks-100-TV_0.jsonl", "r") as f:
46 item = ""
47 for line in f:
48 line = line.strip()
49 item += line
50 if item.endswith("}"):
51 datasets.append(json.loads(item))
52 item = ""
53
54
55
56# 学習したモデルを用いてタスクを実行
57from tqdm import tqdm
58
59# 推論するためにモデルのモードを変更
60FastLanguageModel.for_inference(model)
61
62results = []
63for dt in tqdm(datasets):
64 input = dt["input"]
65
66 prompt = f"""### 指示\n{input}\n### 回答\n"""
67
68 inputs = tokenizer([prompt], return_tensors = "pt").to(model.device)
69
70 outputs = model.generate(**inputs, max_new_tokens = 512, use_cache = True, do_sample=False, repetition_penalty=1.2)
71 prediction = tokenizer.decode(outputs[0], skip_special_tokens=True).split('\n### 回答')[-1]
72
73 results.append({"task_id": dt["task_id"], "input": input, "output": prediction})
741jsonl_id = re.sub(".*/", "", adapter_id)
2with open(f"./{jsonl_id}-outputs.jsonl", 'w', encoding='utf-8') as f:
3 for result in results:
4 json.dump(result, f, ensure_ascii=False)
5 f.write('\n')
6
7# LoRAアダプタだけ保存
8model.push_to_hub_merged(
9 new_model_id+"_lora",
10 tokenizer=tokenizer,
11 save_method="lora",
12 token=HF_TOKEN,
13 private=True
14)