cp_train.py

import torch
from torch.utils.data import DataLoader, random_split

from src.datasets.kfashion import DatasetArguments, KFashionDataset
from src.models.load import load_model
from src.loss.focal_loss import focal_loss
from src.utils.utils import save_model

import os
import wandb
import numpy as np

from torch.optim.lr_scheduler import OneCycleLR
from torch.optim import AdamW
from tqdm import tqdm
from datetime import datetime
from dataclasses import dataclass

from sklearn.metrics import roc_auc_score

from model_args import Args

# Argument Setting
args = Args()

# Path Setting
args.data_dir = './data/kfashion' # data 경로 변경 필요
args.checkpoint_dir = './checkpoint'
args.model_path = None
    
# Training Setting
args.n_epochs = 10
args.num_workers = 2
args.train_batch_size = 64
args.val_batch_size = 64
args.lr = 1e-5
args.wandb_key = None #'36f469dcbd6d8319fb649a92ef277e655fa72886'
args.use_wandb = True if args.wandb_key else False
args.with_cuda = True


def cp_iteration(epoch, model, optimizer, scheduler, dataloader, device, is_train, use_wandb):
    type_str = f'cp train' if is_train else f'cp valid'
    epoch_iterator = tqdm(dataloader)
    
    loss = 0.
    num_iter = len(epoch_iterator)
    total_y_true = []
    total_y_score = []
    
    for iter, batch in enumerate(epoch_iterator, start=1):
        targets = batch['targets'].to(device)
        inputs = {key: value.to(device) for key, value in batch['inputs'].items()}

        input_embeddings = model.batch_encode(inputs)
        probs = model.get_score(input_embeddings)

        running_loss = focal_loss(probs, targets)
        loss += running_loss.item()
        if is_train == True:
            optimizer.zero_grad()
            running_loss.backward()
            optimizer.step()
            if scheduler:
                scheduler.step()

        total_y_true.append(targets.clone().flatten().detach().cpu().bool())
        total_y_score.append(probs.flatten().detach().cpu())
        is_correct = (total_y_true[-1] == (total_y_score[-1] > 0.5))
        running_acc = torch.sum(is_correct).item() / torch.numel(is_correct)

        epoch_iterator.set_description(
            f'Loss: {running_loss:.5f} | Acc: {running_acc:.3f}')
        if use_wandb:
            log = {
                f'{type_str}_loss': running_loss, 
                f'{type_str}_acc': running_acc, 
                f'{type_str}_step': epoch * len(epoch_iterator) + iter
                }
            if (is_train == True) and (scheduler is not None):
                log["learning_rate"] = scheduler.get_last_lr()[0]
            wandb.log(log)
    
    loss = loss / num_iter
    total_y_true = torch.cat(total_y_true)
    total_y_score = torch.cat(total_y_score)
    is_correct = (total_y_true == (total_y_score > 0.5))
    acc = torch.sum(is_correct).item() / torch.numel(is_correct)
    try:
        auc = roc_auc_score(total_y_true, total_y_score)
    except:
        auc = 0
    print( f'[{type_str} END] Epoch: {epoch + 1:03} | loss: {loss:.5f} | Acc: {acc:.3f} | AUC: {auc:.3f}' + '\n')

    return loss, acc, auc


if __name__ == '__main__':
    TASK = 'cp'

    # Wandb
    if args.use_wandb:
        os.environ["WANDB_API_KEY"] = args.wandb_key
        os.environ["WANDB_PROJECT"] = f"OutfitTransformer-{TASK}"
        os.environ["WANDB_LOG_MODEL"] = "all"
        wandb.login()
        run = wandb.init()
    
    date_info = datetime.today().strftime("%y%m%d")
    save_dir = os.path.join(args.checkpoint_dir, TASK, date_info)

    cuda_condition = torch.cuda.is_available() and args.with_cuda
    device = torch.device("cuda:0" if cuda_condition else "cpu")
    
    model, input_processor = load_model(args)
    model.to(device)

    train_dataset_args = DatasetArguments(task_type=TASK, dataset_type='train')
    train_dataset = KFashionDataset(args.data_dir, train_dataset_args, input_processor)
    train_dataloader = DataLoader(
        dataset=train_dataset, batch_size=args.train_batch_size, shuffle=True, num_workers=args.num_workers)
    
    val_dataset_args = DatasetArguments(task_type=TASK, dataset_type='valid')
    val_dataset = KFashionDataset(args.data_dir, val_dataset_args, input_processor)
    val_dataloader = DataLoader(
        dataset=val_dataset, batch_size=args.val_batch_size, shuffle=False, num_workers=args.num_workers)
    
    print(f"TRAIN DATASET : {len(train_dataset)} || VALID DATASET : {len(val_dataset)}")
    
    optimizer = AdamW(model.parameters(), lr=args.lr)
    scheduler = OneCycleLR(optimizer, args.lr, epochs=args.n_epochs, steps_per_epoch=len(train_dataloader))

    best_auc = 0
    for epoch in range(args.n_epochs):
        model.train()
        train_loss, train_acc, train_auc = cp_iteration(
            epoch, model, optimizer, scheduler,
            dataloader=train_dataloader, device=device, is_train=True, use_wandb=args.use_wandb
            )
        model.eval()
        with torch.no_grad():
            val_loss, val_acc, val_auc = cp_iteration(
                epoch, model, optimizer, scheduler,
                dataloader=val_dataloader, device=device, is_train=False, use_wandb=args.use_wandb
                )
        if val_auc >= best_auc:
            best_auc = val_auc
            model_name = f'epoch_{epoch}_AUC_{best_auc:.3f}'
            save_model(model, save_dir, model_name, device)