E2e device cuda (#575)

* use torch.cuda.current_device() instead of local_rank

* ignore NVML errors for gpu stats

* llama lora packing e2e tests
This commit is contained in:
Wing Lian
2023-09-14 22:49:27 -04:00
committed by GitHub
parent 9218ebecd2
commit 24146733db
4 changed files with 52 additions and 6 deletions

View File

@@ -24,6 +24,7 @@ jobs:
- name: Install dependencies - name: Install dependencies
run: | run: |
pip3 install -e . pip3 install -e .
pip3 install flash-attn
pip3 install -r requirements-tests.txt pip3 install -r requirements-tests.txt
- name: Run e2e tests - name: Run e2e tests

View File

@@ -2,6 +2,7 @@
import pynvml import pynvml
import torch import torch
from pynvml.nvml import NVMLError
def gpu_memory_usage(device=0): def gpu_memory_usage(device=0):
@@ -20,11 +21,13 @@ def gpu_memory_usage_smi(device=0):
device = device.index device = device.index
if isinstance(device, str) and device.startswith("cuda:"): if isinstance(device, str) and device.startswith("cuda:"):
device = int(device[5:]) device = int(device[5:])
try:
pynvml.nvmlInit() pynvml.nvmlInit()
handle = pynvml.nvmlDeviceGetHandleByIndex(device) handle = pynvml.nvmlDeviceGetHandleByIndex(device)
info = pynvml.nvmlDeviceGetMemoryInfo(handle) info = pynvml.nvmlDeviceGetMemoryInfo(handle)
return info.used / 1024.0**3 return info.used / 1024.0**3
except NVMLError:
return 0.0
def log_gpu_memory_usage(log, msg, device): def log_gpu_memory_usage(log, msg, device):

View File

@@ -29,7 +29,7 @@ def choose_device(cfg):
cfg.device_map = "auto" cfg.device_map = "auto"
else: else:
if cfg.device.startswith("cuda"): if cfg.device.startswith("cuda"):
cfg.device_map = {"": cfg.local_rank} cfg.device_map = {"": torch.cuda.current_device()}
else: else:
cfg.device_map = {"": cfg.device} cfg.device_map = {"": cfg.device}

View File

@@ -78,3 +78,45 @@ class TestLoraLlama(unittest.TestCase):
dataset_meta = load_datasets(cfg=cfg, cli_args=cli_args) dataset_meta = load_datasets(cfg=cfg, cli_args=cli_args)
train(cfg=cfg, cli_args=cli_args, dataset_meta=dataset_meta) train(cfg=cfg, cli_args=cli_args, dataset_meta=dataset_meta)
def test_lora_packing(self):
cfg = DictDefault(
{
"base_model": "JackFram/llama-68m",
"base_model_config": "JackFram/llama-68m",
"tokenizer_type": "LlamaTokenizer",
"sequence_len": 1024,
"sample_packing": True,
"flash_attention": True,
"load_in_8bit": True,
"adapter": "lora",
"lora_r": 32,
"lora_alpha": 64,
"lora_dropout": 0.05,
"lora_target_linear": True,
"val_set_size": 0.1,
"special_tokens": {
"unk_token": "<unk>",
"bos_token": "<s>",
"eos_token": "</s>",
},
"datasets": [
{
"path": "mhenrichsen/alpaca_2k_test",
"type": "alpaca",
},
],
"num_epochs": 2,
"micro_batch_size": 8,
"gradient_accumulation_steps": 1,
"output_dir": tempfile.mkdtemp(),
"learning_rate": 0.00001,
"optimizer": "adamw_torch",
"lr_scheduler": "cosine",
}
)
normalize_config(cfg)
cli_args = TrainerCliArgs()
dataset_meta = load_datasets(cfg=cfg, cli_args=cli_args)
train(cfg=cfg, cli_args=cli_args, dataset_meta=dataset_meta)