ac77da96da
* use smaller pretrained models for ci * more steps for loss check * fix tests * more train steps * fix losses
506 lines
18 KiB
Python
506 lines
18 KiB
Python
"""Test module for FSDP2 multi-GPU functionality."""
|
|
|
|
from pathlib import Path
|
|
|
|
import pytest
|
|
import yaml
|
|
from accelerate.test_utils import execute_subprocess_async
|
|
from transformers.testing_utils import get_torch_dist_unique_port
|
|
|
|
from axolotl.utils.dict import DictDefault
|
|
|
|
from tests.e2e.utils import check_tensorboard_loss_decreased, require_torch_2_7_0
|
|
|
|
AXOLOTL_ROOT = Path(__file__).parent.parent.parent.parent
|
|
|
|
|
|
def verify_training_success(temp_dir):
|
|
"""Verify that training completed successfully — artifacts, no-NaN, loss
|
|
stayed in qwen2-pretraining scale (tiny-qwen2-129m final pretrain CE ~3.92).
|
|
"""
|
|
output_path = Path(temp_dir)
|
|
|
|
model_files = list(output_path.glob("*.bin")) + list(
|
|
output_path.glob("*.safetensors")
|
|
)
|
|
assert len(model_files) > 0, "No model files found - training may have failed"
|
|
|
|
checkpoint_files = list(output_path.glob("checkpoint-*"))
|
|
assert len(checkpoint_files) > 0, (
|
|
"No checkpoint files found - training may have failed"
|
|
)
|
|
|
|
check_tensorboard_loss_decreased(
|
|
temp_dir + "/runs",
|
|
initial_window=10,
|
|
final_window=10,
|
|
max_initial=5.0,
|
|
max_final=4.7,
|
|
)
|
|
|
|
|
|
class TestFSDP2:
|
|
"""Test class for FSDP2 functionality."""
|
|
|
|
@require_torch_2_7_0
|
|
@pytest.mark.parametrize(
|
|
"fsdp_cpu_ram_efficient_loading",
|
|
[True, False],
|
|
)
|
|
def test_fft_sft(self, temp_dir, fsdp_cpu_ram_efficient_loading):
|
|
cfg = DictDefault(
|
|
{
|
|
"base_model": "axolotl-ai-co/tiny-qwen2-129m",
|
|
"sequence_len": 2048,
|
|
"val_set_size": 0.01,
|
|
"datasets": [
|
|
{
|
|
"path": "tatsu-lab/alpaca",
|
|
"type": "alpaca",
|
|
"split": "train[:10%]",
|
|
},
|
|
],
|
|
"num_epochs": 1,
|
|
"max_steps": 80,
|
|
"warmup_steps": 5,
|
|
"micro_batch_size": 2,
|
|
"gradient_accumulation_steps": 1,
|
|
"output_dir": temp_dir,
|
|
"learning_rate": 2e-4,
|
|
"optimizer": "adamw_torch_fused",
|
|
"lr_scheduler": "cosine",
|
|
"flash_attention": True,
|
|
"fsdp_version": 2,
|
|
"fsdp_config": {
|
|
"offload_params": False,
|
|
"cpu_ram_efficient_loading": fsdp_cpu_ram_efficient_loading,
|
|
"transformer_layer_cls_to_wrap": "Qwen2DecoderLayer",
|
|
"state_dict_type": "FULL_STATE_DICT",
|
|
"auto_wrap_policy": "TRANSFORMER_BASED_WRAP",
|
|
"reshard_after_forward": True,
|
|
},
|
|
"use_tensorboard": True,
|
|
"seed": 42,
|
|
"sample_packing": True,
|
|
"pad_to_sequence_len": True,
|
|
"bf16": True,
|
|
}
|
|
)
|
|
|
|
# write cfg to yaml file
|
|
Path(temp_dir).mkdir(parents=True, exist_ok=True)
|
|
with open(Path(temp_dir) / "config.yaml", "w", encoding="utf-8") as fout:
|
|
fout.write(yaml.dump(cfg.to_dict(), Dumper=yaml.Dumper))
|
|
|
|
execute_subprocess_async(
|
|
[
|
|
"axolotl",
|
|
"train",
|
|
str(Path(temp_dir) / "config.yaml"),
|
|
"--num-processes",
|
|
"2",
|
|
"--main-process-port",
|
|
f"{get_torch_dist_unique_port()}",
|
|
]
|
|
)
|
|
|
|
verify_training_success(temp_dir)
|
|
|
|
@require_torch_2_7_0
|
|
@pytest.mark.parametrize("peft_use_dora", [True, False])
|
|
def test_lora_sft(self, temp_dir, peft_use_dora):
|
|
cfg = DictDefault(
|
|
{
|
|
"base_model": "axolotl-ai-co/tiny-qwen2-129m",
|
|
"sequence_len": 2048,
|
|
"val_set_size": 0.01,
|
|
"datasets": [
|
|
{
|
|
"path": "tatsu-lab/alpaca",
|
|
"type": "alpaca",
|
|
"split": "train[:10%]",
|
|
},
|
|
],
|
|
"peft_use_dora": peft_use_dora,
|
|
"adapter": "lora",
|
|
"lora_r": 8,
|
|
"lora_alpha": 16,
|
|
"lora_dropout": 0.0,
|
|
"lora_target_linear": True,
|
|
"num_epochs": 1,
|
|
"max_steps": 80,
|
|
"warmup_steps": 5,
|
|
"micro_batch_size": 2,
|
|
"gradient_accumulation_steps": 1,
|
|
"output_dir": temp_dir,
|
|
"learning_rate": 1e-3,
|
|
"optimizer": "adamw_torch_fused",
|
|
"lr_scheduler": "cosine",
|
|
"flash_attention": True,
|
|
"fsdp_version": 2,
|
|
"fsdp_config": {
|
|
"offload_params": False,
|
|
"cpu_ram_efficient_loading": False,
|
|
"transformer_layer_cls_to_wrap": "Qwen2DecoderLayer",
|
|
"state_dict_type": "FULL_STATE_DICT",
|
|
"auto_wrap_policy": "TRANSFORMER_BASED_WRAP",
|
|
"reshard_after_forward": True,
|
|
},
|
|
"use_tensorboard": True,
|
|
"seed": 42,
|
|
"sample_packing": True,
|
|
"pad_to_sequence_len": True,
|
|
"bf16": True,
|
|
# explicitly disable LORA kernels, as they may be auto-enabled
|
|
"lora_mlp_kernel": False,
|
|
"lora_qkv_kernel": False,
|
|
"lora_o_kernel": False,
|
|
}
|
|
)
|
|
|
|
# write cfg to yaml file
|
|
Path(temp_dir).mkdir(parents=True, exist_ok=True)
|
|
with open(Path(temp_dir) / "config.yaml", "w", encoding="utf-8") as fout:
|
|
fout.write(yaml.dump(cfg.to_dict(), Dumper=yaml.Dumper))
|
|
|
|
execute_subprocess_async(
|
|
[
|
|
"axolotl",
|
|
"train",
|
|
str(Path(temp_dir) / "config.yaml"),
|
|
"--num-processes",
|
|
"2",
|
|
"--main-process-port",
|
|
f"{get_torch_dist_unique_port()}",
|
|
]
|
|
)
|
|
|
|
verify_training_success(temp_dir)
|
|
|
|
@require_torch_2_7_0
|
|
def test_lora_sft_kernels(self, temp_dir):
|
|
cfg = DictDefault(
|
|
{
|
|
"base_model": "axolotl-ai-co/tiny-qwen2-129m",
|
|
"sequence_len": 2048,
|
|
"val_set_size": 0.01,
|
|
"datasets": [
|
|
{
|
|
"path": "tatsu-lab/alpaca",
|
|
"type": "alpaca",
|
|
"split": "train[:10%]",
|
|
},
|
|
],
|
|
"adapter": "lora",
|
|
"lora_r": 8,
|
|
"lora_alpha": 16,
|
|
"lora_target_linear": True,
|
|
"num_epochs": 1,
|
|
"max_steps": 80,
|
|
"warmup_steps": 5,
|
|
"micro_batch_size": 2,
|
|
"gradient_accumulation_steps": 1,
|
|
"output_dir": temp_dir,
|
|
"learning_rate": 1e-3,
|
|
"optimizer": "adamw_torch_fused",
|
|
"lr_scheduler": "cosine",
|
|
"flash_attention": True,
|
|
"fsdp_version": 2,
|
|
"fsdp_config": {
|
|
"offload_params": False,
|
|
"cpu_ram_efficient_loading": False,
|
|
"transformer_layer_cls_to_wrap": "Qwen2DecoderLayer",
|
|
"state_dict_type": "FULL_STATE_DICT",
|
|
"auto_wrap_policy": "TRANSFORMER_BASED_WRAP",
|
|
"reshard_after_forward": True,
|
|
},
|
|
"use_tensorboard": True,
|
|
"seed": 42,
|
|
"sample_packing": True,
|
|
"pad_to_sequence_len": True,
|
|
"bf16": True,
|
|
"lora_mlp_kernel": True,
|
|
"lora_qkv_kernel": True,
|
|
"lora_o_kernel": True,
|
|
}
|
|
)
|
|
|
|
# write cfg to yaml file
|
|
Path(temp_dir).mkdir(parents=True, exist_ok=True)
|
|
with open(Path(temp_dir) / "config.yaml", "w", encoding="utf-8") as fout:
|
|
fout.write(yaml.dump(cfg.to_dict(), Dumper=yaml.Dumper))
|
|
|
|
execute_subprocess_async(
|
|
[
|
|
"axolotl",
|
|
"train",
|
|
str(Path(temp_dir) / "config.yaml"),
|
|
"--num-processes",
|
|
"2",
|
|
"--main-process-port",
|
|
f"{get_torch_dist_unique_port()}",
|
|
]
|
|
)
|
|
|
|
verify_training_success(temp_dir)
|
|
|
|
@require_torch_2_7_0
|
|
def test_qlora_sft(self, temp_dir):
|
|
cfg = DictDefault(
|
|
{
|
|
"base_model": "axolotl-ai-co/tiny-qwen2-129m",
|
|
"sequence_len": 2048,
|
|
"val_set_size": 0.01,
|
|
"datasets": [
|
|
{
|
|
"path": "tatsu-lab/alpaca",
|
|
"type": "alpaca",
|
|
"split": "train[:10%]",
|
|
},
|
|
],
|
|
"load_in_4bit": True,
|
|
"adapter": "qlora",
|
|
"lora_r": 8,
|
|
"lora_alpha": 16,
|
|
"lora_dropout": 0.0,
|
|
"lora_target_linear": True,
|
|
"num_epochs": 1,
|
|
"max_steps": 80,
|
|
"warmup_steps": 5,
|
|
"micro_batch_size": 2,
|
|
"gradient_accumulation_steps": 1,
|
|
"output_dir": temp_dir,
|
|
"learning_rate": 1e-3,
|
|
"optimizer": "adamw_torch_fused",
|
|
"lr_scheduler": "cosine",
|
|
"flash_attention": True,
|
|
"fsdp_version": 2,
|
|
"fsdp_config": {
|
|
"offload_params": False,
|
|
"cpu_ram_efficient_loading": False,
|
|
"transformer_layer_cls_to_wrap": "Qwen2DecoderLayer",
|
|
"state_dict_type": "FULL_STATE_DICT",
|
|
"auto_wrap_policy": "TRANSFORMER_BASED_WRAP",
|
|
"reshard_after_forward": True,
|
|
},
|
|
"use_tensorboard": True,
|
|
"seed": 42,
|
|
"sample_packing": True,
|
|
"pad_to_sequence_len": True,
|
|
"bf16": True,
|
|
}
|
|
)
|
|
|
|
# write cfg to yaml file
|
|
Path(temp_dir).mkdir(parents=True, exist_ok=True)
|
|
with open(Path(temp_dir) / "config.yaml", "w", encoding="utf-8") as fout:
|
|
fout.write(yaml.dump(cfg.to_dict(), Dumper=yaml.Dumper))
|
|
|
|
execute_subprocess_async(
|
|
[
|
|
"axolotl",
|
|
"train",
|
|
str(Path(temp_dir) / "config.yaml"),
|
|
"--num-processes",
|
|
"2",
|
|
"--main-process-port",
|
|
f"{get_torch_dist_unique_port()}",
|
|
]
|
|
)
|
|
|
|
verify_training_success(temp_dir)
|
|
|
|
@require_torch_2_7_0
|
|
def test_qlora_sft_kernels(self, temp_dir):
|
|
cfg = DictDefault(
|
|
{
|
|
"base_model": "axolotl-ai-co/tiny-qwen2-129m",
|
|
"sequence_len": 2048,
|
|
"val_set_size": 0.01,
|
|
"datasets": [
|
|
{
|
|
"path": "tatsu-lab/alpaca",
|
|
"type": "alpaca",
|
|
"split": "train[:10%]",
|
|
},
|
|
],
|
|
"load_in_4bit": True,
|
|
"adapter": "qlora",
|
|
"lora_r": 8,
|
|
"lora_alpha": 16,
|
|
"lora_target_linear": True,
|
|
"num_epochs": 1,
|
|
"max_steps": 80,
|
|
"warmup_steps": 5,
|
|
"micro_batch_size": 2,
|
|
"gradient_accumulation_steps": 1,
|
|
"output_dir": temp_dir,
|
|
"learning_rate": 1e-3,
|
|
"optimizer": "adamw_torch_fused",
|
|
"lr_scheduler": "cosine",
|
|
"flash_attention": True,
|
|
"fsdp_version": 2,
|
|
"fsdp_config": {
|
|
"offload_params": False,
|
|
"cpu_ram_efficient_loading": False,
|
|
"transformer_layer_cls_to_wrap": "Qwen2DecoderLayer",
|
|
"state_dict_type": "FULL_STATE_DICT",
|
|
"auto_wrap_policy": "TRANSFORMER_BASED_WRAP",
|
|
"reshard_after_forward": True,
|
|
},
|
|
"use_tensorboard": True,
|
|
"seed": 42,
|
|
"sample_packing": True,
|
|
"pad_to_sequence_len": True,
|
|
"bf16": True,
|
|
"lora_mlp_kernel": True,
|
|
"lora_qkv_kernel": True,
|
|
"lora_o_kernel": True,
|
|
}
|
|
)
|
|
|
|
# write cfg to yaml file
|
|
Path(temp_dir).mkdir(parents=True, exist_ok=True)
|
|
with open(Path(temp_dir) / "config.yaml", "w", encoding="utf-8") as fout:
|
|
fout.write(yaml.dump(cfg.to_dict(), Dumper=yaml.Dumper))
|
|
|
|
execute_subprocess_async(
|
|
[
|
|
"axolotl",
|
|
"train",
|
|
str(Path(temp_dir) / "config.yaml"),
|
|
"--num-processes",
|
|
"2",
|
|
"--main-process-port",
|
|
f"{get_torch_dist_unique_port()}",
|
|
]
|
|
)
|
|
|
|
verify_training_success(temp_dir)
|
|
|
|
@pytest.mark.skip(reason="slow test w cu129 + torch 2.9.1 + py3.12")
|
|
@require_torch_2_7_0
|
|
def test_dpo_fft(self, temp_dir):
|
|
cfg = DictDefault(
|
|
{
|
|
"base_model": "axolotl-ai-co/tiny-qwen2-129m",
|
|
"sequence_len": 2048,
|
|
"val_set_size": 0.01,
|
|
"rl": "dpo",
|
|
"chat_template": "chatml",
|
|
"datasets": [
|
|
{
|
|
"path": "Intel/orca_dpo_pairs",
|
|
"split": "train",
|
|
"type": "chatml.intel",
|
|
},
|
|
],
|
|
"num_epochs": 1,
|
|
"max_steps": 20,
|
|
"micro_batch_size": 2,
|
|
"gradient_accumulation_steps": 1,
|
|
"output_dir": temp_dir,
|
|
"learning_rate": 2e-4,
|
|
"optimizer": "adamw_torch_fused",
|
|
"lr_scheduler": "cosine",
|
|
"flash_attention": True,
|
|
"fsdp_version": 2,
|
|
"fsdp_config": {
|
|
"offload_params": False,
|
|
"cpu_ram_efficient_loading": False,
|
|
"transformer_layer_cls_to_wrap": "Qwen2DecoderLayer",
|
|
"state_dict_type": "FULL_STATE_DICT",
|
|
"auto_wrap_policy": "TRANSFORMER_BASED_WRAP",
|
|
"reshard_after_forward": True,
|
|
},
|
|
"use_tensorboard": True,
|
|
"seed": 42,
|
|
"sample_packing": True,
|
|
"pad_to_sequence_len": True,
|
|
}
|
|
)
|
|
|
|
# write cfg to yaml file
|
|
Path(temp_dir).mkdir(parents=True, exist_ok=True)
|
|
with open(Path(temp_dir) / "config.yaml", "w", encoding="utf-8") as fout:
|
|
fout.write(yaml.dump(cfg.to_dict(), Dumper=yaml.Dumper))
|
|
|
|
execute_subprocess_async(
|
|
[
|
|
"axolotl",
|
|
"train",
|
|
str(Path(temp_dir) / "config.yaml"),
|
|
"--num-processes",
|
|
"2",
|
|
"--main-process-port",
|
|
f"{get_torch_dist_unique_port()}",
|
|
]
|
|
)
|
|
|
|
verify_training_success(temp_dir)
|
|
|
|
@pytest.mark.skip(reason="slow test w cu129 + torch 2.9.1 + py3.12")
|
|
@require_torch_2_7_0
|
|
def test_dpo_lora(self, temp_dir):
|
|
cfg = DictDefault(
|
|
{
|
|
"base_model": "axolotl-ai-co/tiny-qwen2-129m",
|
|
"sequence_len": 2048,
|
|
"rl": "dpo",
|
|
"chat_template": "chatml",
|
|
"datasets": [
|
|
{
|
|
"path": "Intel/orca_dpo_pairs",
|
|
"split": "train",
|
|
"type": "chatml.intel",
|
|
},
|
|
],
|
|
"adapter": "lora",
|
|
"lora_r": 8,
|
|
"lora_alpha": 16,
|
|
"lora_dropout": 0.05,
|
|
"lora_target_linear": True,
|
|
"num_epochs": 1,
|
|
"max_steps": 20,
|
|
"micro_batch_size": 2,
|
|
"gradient_accumulation_steps": 1,
|
|
"output_dir": temp_dir,
|
|
"learning_rate": 1e-3,
|
|
"optimizer": "adamw_torch_fused",
|
|
"lr_scheduler": "cosine",
|
|
"flash_attention": True,
|
|
"fsdp_version": 2,
|
|
"fsdp_config": {
|
|
"offload_params": False,
|
|
"cpu_ram_efficient_loading": False,
|
|
"transformer_layer_cls_to_wrap": "Qwen2DecoderLayer",
|
|
"state_dict_type": "FULL_STATE_DICT",
|
|
"auto_wrap_policy": "TRANSFORMER_BASED_WRAP",
|
|
"reshard_after_forward": True,
|
|
},
|
|
"use_tensorboard": True,
|
|
"seed": 42,
|
|
"sample_packing": True,
|
|
"pad_to_sequence_len": True,
|
|
}
|
|
)
|
|
|
|
# write cfg to yaml file
|
|
Path(temp_dir).mkdir(parents=True, exist_ok=True)
|
|
with open(Path(temp_dir) / "config.yaml", "w", encoding="utf-8") as fout:
|
|
fout.write(yaml.dump(cfg.to_dict(), Dumper=yaml.Dumper))
|
|
|
|
execute_subprocess_async(
|
|
[
|
|
"axolotl",
|
|
"train",
|
|
str(Path(temp_dir) / "config.yaml"),
|
|
"--num-processes",
|
|
"2",
|
|
"--main-process-port",
|
|
f"{get_torch_dist_unique_port()}",
|
|
]
|
|
)
|
|
|
|
verify_training_success(temp_dir)
|