base_Agg_kinetics.py

import os
import copy
import torch
import shutil
import time
import warnings
import sys
import numpy as np
import random
from ops import Augment
import torch.nn.functional as F
from torch.nn.utils import clip_grad_norm_
from tensorboardX import SummaryWriter
from opts import parser
from ops.mapmeter import mAPMeter, LTMeter
from ops.utils import AverageMeter, accuracy, LTAverageMeter, perclsaccuracy, LTconfMeter

from ops import losses
from tools import utils

from models import models
from dataset import dutils_kinetics
from dataset.imbalance_minikinetics import TestDataset, imbalance_minikinetics

def setup_seed(seed):
    np.random.seed(seed)
    random.seed(seed)
    torch.manual_seed(seed)
    torch.cuda.manual_seed(seed)

def adjust_learning_rate(optimizer, epoch, lr_type, lr_steps):
    if lr_type == 'step':
        decay = 0.1 ** (sum(epoch >= np.array(lr_steps)))
        lr = args.lr * decay

    elif lr_type == 'cos':
        import math
        lr = 0.5 * args.lr * (1 + math.cos(math.pi * epoch / args.epochs))

    else:
        raise NotImplementedError

    for param_group in optimizer.param_groups:
        param_group['lr'] = lr

def check_rootfolders():
    """Create log and model folder"""
    folders_util = [args.root_log, args.root_model,
                    os.path.join(args.root_log, args.store_name),
                    os.path.join(args.root_model, args.store_name)]
    for folder in folders_util:
        if not os.path.exists(folder):
            print('creating folder ' + folder)
            os.mkdir(folder)

def save_checkpoint(state, is_best):
    filename = '%s/%s/ckpt.pth.tar' % (args.root_model, args.store_name)
    torch.save(state, filename)
    if is_best:
        shutil.copyfile(filename, filename.replace('pth.tar', 'best.pth.tar'))

def load_data(num_class, train_dir, val_dir):
    train_dataset = imbalance_minikinetics(root='./data/train.lst',
                                           input_dir=train_dir,
                                           imb_factor=args.imb_factor,
                                           num_frames=args.train_num_frames)
    val_dataset = TestDataset(root='./data/val.lst',
                              input_dir=val_dir, Class_converter=train_dataset.Class_converter)

    cls_num_list = train_dataset.num_list
    import copy
    num_list = copy.deepcopy(cls_num_list)
    print(cls_num_list)
    train_dataloader = torch.utils.data.DataLoader(train_dataset, batch_size=args.batch_size, \
                        shuffle=True, num_workers=args.workers, pin_memory=True)
    val_dataloader = torch.utils.data.DataLoader(val_dataset, batch_size=args.batch_size, \
                        shuffle=False, num_workers=args.workers, pin_memory=True)

    cls_num_list = np.array([num / sum(cls_num_list) for num in cls_num_list])
    cls_num_list = (cls_num_list - cls_num_list.min()) / (cls_num_list.max() - cls_num_list.min())

    sampling_prob = cls_num_list * args.train_num_frames
    sampling_prob[sampling_prob < args.lb] = args.lb

    target_smooth_factor = 1 - cls_num_list
    target_smooth_factor += args.calib_bias
    smooth_factor = torch.FloatTensor(target_smooth_factor)

    return train_dataloader, val_dataloader, sampling_prob, smooth_factor, cls_num_list, num_list

def main():
   
    global args, best_mAP, criterion, optimizer, tf_writer, log_training
    args = parser.parse_args()
    args.store_name += args.store_name + '_' + str(args.imb_factor)
    
    best_mAP = 0


    start_epoch = args.start_epoch     
    num_class = args.num_class
    if args.resample != 'None':
        args.reduce = "none"
    print ("########################################################################\n")
    print ("Feature name: {} \nNumber of class: {} \nTrain frames: {} \nVal frames: {}\nReduction: {}".\
            format(args.feature_name, args.num_class, args.train_num_frames, args.val_num_frames, args.reduce))
    print ("Applied long-tailed strategies: \n")
    print ("\tAugmentation: {} \t Re-weighting: {} \t Re-sampling: {} \n". \
            format(args.augment, args.loss_func, args.resample))
    print ("######################################################################## \n") 
    check_rootfolders()
    setup_seed(args.seed)

    train_dir, val_dir = dutils_kinetics.get_feature_path(args.feature_name)
    feature_dim = dutils_kinetics.get_feature_dim(args.feature_name)
    # args.train_list, args.val_list = dutils_kinetics.get_label_path()

    train_loader, val_loader, sampling_prob, smooth_factor, cls_num_list, num_list = load_data(num_class, train_dir, val_dir)
    args.lc_list = num_list
    criterion = utils.find_class_by_name(args.loss_func, [losses])(args, logits=True, reduce=args.reduce)
    indices = utils.get_indices(num_list, head=args.head, tail=args.tail)
    print(indices)

    model = utils.find_class_by_name(args.model_name, [models])(3072, num_class)
    model = model.cuda()
    vladmodel = utils.find_class_by_name('NetVLADModel_Aggregator', [models])(feature_dim, num_class)
    vladmodel = vladmodel.cuda()
    MHA = utils.find_class_by_name('MultiHeadAttention_Aggregator', [models])().cuda()
    if args.resume != "": 
        print ("=> Loading checkpoint {}".format(args.resume))
        
        ckpt = torch.load(args.resume)
        best_mAP = ckpt['best_mAP']
        start_epoch = ckpt['epoch'] + 1
        acc1 = ckpt['Acc@1']
        acc5 = ckpt['Acc@5']
        sd = ckpt['state_dict']
        sdMHA = ckpt['MHA']
        sdvlad = ckpt['vlad']
        print ("Loaded checkpoint {} epoch {}: best_mAP {} | Acc@1 {} | Acc@5 {}". \
                format(args.resume, start_epoch, best_mAP, acc1, acc5))

        model.load_state_dict(sd)
        MHA.load_state_dict(sdMHA)
        vladmodel.load_state_dict(sdvlad)
    if args.evaluate:
        if args.resume != "":
            acc1, acc5, mAP = validate(val_loader, model, 0, None, indices)
        else:
            print('please enter args.resume with args.evaluate')
        exit(0)

    print ("Params to learn:")
    params_to_update = []
    for name, param in model.named_parameters():
        if param.requires_grad == True:
            params_to_update.append(param)
            print ('\t', name)
    for name, param in MHA.named_parameters():
        params_to_update.append(param)
        print ('\t', name)

    for name, param in vladmodel.named_parameters():
        if param.requires_grad == True:
            params_to_update.append(param)
            print('\t', name)
    optimizer = torch.optim.Adam(params_to_update, lr=args.lr)
    
    log_training = open(os.path.join(args.root_log, args.store_name, 'log.csv'),'w')
    tf_writer = SummaryWriter(log_dir=os.path.join(args.root_log, args.store_name))

    for epoch in range(start_epoch, args.epochs):
        adjust_learning_rate(optimizer, epoch, args.lr_type, args.lr_steps)
        print ("Training for Epoch {}".format(epoch))
        if args.resample != "None":
            rs_train(train_loader, model, epoch, log_training)
        else:
            train(train_loader, model, vladmodel, MHA, epoch, log_training, indices)
        if (epoch + 1) % args.eval_freq == 0 or epoch == args.epochs - 1:
            acc1, acc5, mAP = validate(val_loader, model, vladmodel, MHA, epoch, log_training, indices)
            is_best = mAP > best_mAP
            best_mAP = max(mAP, best_mAP)
            tf_writer.add_scalar('best_mAP/test_best', best_mAP, epoch)
            
            print ('Test Epoch {}: Acc@1: {} | Acc@5: {} | mAP: {} | best_mAP: {}'.\
                    format(epoch, acc1, acc5, mAP, best_mAP))

            save_checkpoint({
            'epoch': epoch + 1,
            'feature': args.feature_name,
            'state_dict': model.state_dict(),
            'MHA': MHA.state_dict(),
            'vlad': vladmodel.state_dict(),
            'optimizer': optimizer.state_dict(),
            'best_mAP': best_mAP,
            'Acc@1': acc1,
            'Acc@5': acc5},
            is_best)

def train(loader, model, vladmodel, MHA, epoch, log, indices):
    batch_time = AverageMeter()
    data_time = AverageMeter()
    losses = AverageMeter()
    top1 = AverageMeter()
    top5 = AverageMeter()
    LTtop1 = LTAverageMeter(indices)
    LTtop5 = LTAverageMeter(indices)
    LTconf = LTconfMeter(indices)
    mAP = mAPMeter()
    temp_var = AverageMeter()
    model.train()
    vladmodel.train()
    MHA.train()
    end = time.time()
    
    if args.loss_func == 'LDAM':
        # apply DRW to LDAM

        criterion.reset_epoch(epoch)
    for i, (vid, feature, target, index, label) in enumerate(loader):
        label = label
        feature = feature.cuda()
        target = target.float().cuda(non_blocking=True)
        temporal_variance = feature.var(1).mean()
        v_feature = vladmodel(feature).unsqueeze(1)
        q_feature, attn = MHA(feature, feature, feature)
        q_feature = torch.cat([v_feature, q_feature], dim=2)
        # print(q_feature.shape)
        if args.augment == "mixup":
            gamma = np.random.beta(1.0, 1.0)
            mixed_input, mixed_target = Augment.mixup(q_feature, target, gamma)
            prediction, output = model(mixed_input)
            loss = criterion(output, mixed_target)
        elif args.augment == "None":
            prediction, output = model(q_feature)
            loss = criterion(output, target)
        else:
            print ("{} not implemented. Please choose ['mixup', 'None'].".\
                    format(args.augment))
            raise NotImplementedError
        
        losses.update(loss.item(), output.size(0))
        temp_var.update(temporal_variance.item(), feature.size(0))
        with torch.no_grad():
            prec1, prec5 = accuracy(output.data, target, topk=(1, 5))
            corr1, corr5 = perclsaccuracy(output.data, target, topk=(1, 5))
            corr1 = corr1.data.cpu()
            corr5 = corr5.data.cpu()
            top1.update(prec1, output.size(0))
            top5.update(prec5, output.size(0))
            LTtop1.update(corr1, label)
            LTtop5.update(corr5, label)
            LTconf.update(prediction.cpu(), label)
        
        # accumulate gradient for each parameter
        loss.backward()

        if args.clip_gradient is not None:
            total_norm = clip_grad_norm_(model.parameters(), args.clip_gradient)
        
        # update parameters based on current gradients
        optimizer.step()
        optimizer.zero_grad()

        # measure elapsed time
        batch_time.update(time.time() - end)
        end = time.time()

        if i % args.print_freq == 0:
            output = ('Epoch: [{0}][{1}/{2}], lr: {lr:.5f}\t'
                      'Time {batch_time.val:.3f} ({batch_time.avg:.3f})\t'
                      'Loss {loss.val:.4f} ({loss.avg:.4f})\t'
                      'Prec@1 {top1.val:.3f} ({top1.avg:.3f})\t'
                      'Prec@5 {top5.val:.3f} ({top5.avg:.3f})\t'
                      'tempvar {temp_var.avg:.5f}\n'
                      .format(
                epoch, i, len(loader), batch_time=batch_time,
                data_time=data_time, loss=losses, top1=top1, top5=top5, temp_var=temp_var, \
                lr=optimizer.param_groups[-1]['lr']))

            lt_accoutput = (
                'Head@1 {htop1:.5f} | Head@5 {htop5:.5f} | Medium@1 {mtop1:.5f} | Medium@5 {mtop5:.5f} | Tail@1 {ttop1:.5f} | Tail@5 {ttop5:.5f}'
                    .format(htop1=LTtop1.value()["head"], htop5=LTtop5.value()["head"], mtop1=LTtop1.value()["medium"],
                            mtop5=LTtop5.value()["medium"], ttop1=LTtop1.value()["tail"], ttop5=LTtop5.value()["tail"]))

            # print(lt_accoutput)

            sys.stdout.write('\r')
            sys.stdout.write(output)
            sys.stdout.flush()

            sys.stdout.write('\r')
            sys.stdout.write(lt_accoutput)
            sys.stdout.flush()

            head_conf = LTconf.value()["head"]
            medium_conf = LTconf.value()["medium"]
            tail_conf = LTconf.value()["tail"]
            head_cconf = LTconf.value()["head_c"]
            medium_cconf = LTconf.value()["medium_c"]
            tail_cconf = LTconf.value()["tail_c"]

            lt_confoutput = (
                'Confidence : Head {head_conf:.5f} | Medium {medium_conf:.5f} | Tail {tail_conf:.5f} \n Correct Conf : cHead {head_cconf:.5f} | Medium {medium_cconf:.5f} | Tail {tail_cconf:.5f}'
                    .format(head_conf=head_conf, medium_conf=medium_conf, tail_conf=tail_conf,
                            head_cconf=head_cconf, medium_cconf=medium_cconf, tail_cconf=tail_cconf))
            sys.stdout.write('\r')
            sys.stdout.write(lt_confoutput)
            sys.stdout.flush()

            # print(output)

            log.write(output)
            log.write(lt_accoutput)
            log.write(lt_confoutput)
            log.flush()
    output = (
        'Training Results: Accuracy Prec@1,5 {top1.avg:.5f} {top5.avg:.5f} | Loss {loss.avg:.5f} | tempvar {temp_var.avg:.5f}'
        .format(top1=top1, top5=top5, loss=losses, temp_var=temp_var))
    print(output)
    tf_writer.add_scalar('loss/train_epoch', losses.avg, epoch)
    tf_writer.add_scalar('acc/train_top1', top1.avg, epoch)
    tf_writer.add_scalar('acc/train_top5', top5.avg, epoch)
    tf_writer.add_scalar('lr', optimizer.param_groups[-1]['lr'], epoch)


def validate(loader, model, vladmodel, MHA, epoch, log, indices):
    batch_time = AverageMeter()
    losses = AverageMeter()
    top1 = AverageMeter()
    top5 = AverageMeter()
    mAP = mAPMeter()
    LTtop1 = LTAverageMeter(indices)
    LTtop5 = LTAverageMeter(indices)
    LTmAP =LTMeter(indices)
    temp_var = AverageMeter()
    model.eval()
    MHA.eval()
    vladmodel.eval()
    LTconf = LTconfMeter(indices)
    end = time.time()
    with torch.no_grad():
        # vid_id, feature, onehotlabel, index
        for i, (vid, feature, target, index, label) in enumerate(loader):
            label = label
            feature = feature.cuda()
            target = target.float().cuda()
            temporal_variance = feature.var(1).mean()
            v_feature = vladmodel(feature).unsqueeze(1)
            q_feature, attn = MHA(feature, feature, feature)
            q_feature = torch.cat([v_feature, q_feature], dim=2)
            prediction, output = model(q_feature)
            
            loss = criterion(output, target)

            prec1, prec5 = accuracy(output.data, target, topk=(1, 5))
            corr1, corr5 = perclsaccuracy(output.data, target, topk=(1, 5))
            corr1 = corr1.data.cpu()
            corr5 = corr5.data.cpu()
            losses.update(loss.item(), feature.size(0))
            temp_var.update(temporal_variance.item(), feature.size(0))
            top1.update(prec1, feature.size(0))
            top5.update(prec5, feature.size(0))
            LTtop1.update(corr1, label)
            LTtop5.update(corr5, label)
            LTconf.update(prediction.cpu(), label)
            mAP.add(prediction.cpu(), target)
            LTmAP.add(prediction.cpu(), target)
           
     
            batch_time.update(time.time() - end)
            end = time.time()

        head_map = LTmAP.value()["head"]
        medium_map = LTmAP.value()["medium"]
        tail_map = LTmAP.value()["tail"]

    output = (
        'Testing Results: Accuracy Prec@1,5 {top1.avg:.5f} {top5.avg:.5f} | Loss {loss.avg:.5f} | tempvar {temp_var.avg:.5f}'
            .format(top1=top1, top5=top5, loss=losses, temp_var=temp_var))

    lt_accoutput = (
        'Head@1 {htop1:.5f} H@5 {htop5:.5f} | M@1 {mtop1:.5f} M@5 {mtop5:.5f} | T@1 {ttop1:.5f} T@5 {ttop5:.5f}'
        .format(htop1=LTtop1.value()["head"], htop5=LTtop5.value()["head"], mtop1=LTtop1.value()["medium"],
                mtop5=LTtop5.value()["medium"], ttop1=LTtop1.value()["tail"], ttop5=LTtop5.value()["tail"]))


    print('\n',lt_accoutput)
    print(output)
    lt_output = ("Overall mAP = {:.3f} {:.5f} {:.5f} {:.5f}".\
            format(mAP.avg(), head_map, medium_map, tail_map))
    print (lt_output)

    head_conf = LTconf.value()["head"]
    medium_conf = LTconf.value()["medium"]
    tail_conf = LTconf.value()["tail"]
    head_cconf = LTconf.value()["head_c"]
    medium_cconf = LTconf.value()["medium_c"]
    tail_cconf = LTconf.value()["tail_c"]

    lt_confoutput = (
        'Confidence : Head {head_conf:.5f} | Medium {medium_conf:.5f} | Tail {tail_conf:.5f} \n Correct Conf : cHead {head_cconf:.5f} | Medium {medium_cconf:.5f} | Tail {tail_cconf:.5f}'
            .format(head_conf=head_conf, medium_conf=medium_conf, tail_conf=tail_conf,
                    head_cconf=head_cconf, medium_cconf=medium_cconf, tail_cconf=tail_cconf))
    if log is not None:
        log.write(output + '  mAP {}\n'.format(mAP.avg()))
        log.write(lt_output+'\n')
        log.flush()

    if tf_writer is not None:
        tf_writer.add_scalar('loss/test', losses.avg, epoch)
        tf_writer.add_scalar('acc/test_top1', top1.avg, epoch)
        tf_writer.add_scalar('acc/test_top5', top5.avg, epoch)
        tf_writer.add_scalar('mAP/test', mAP.avg(), epoch)
    return top1.avg, top5.avg, mAP.avg()

def validate_pred_saveall(loader, model, epoch, indices):
    batch_time = AverageMeter()
    losses = AverageMeter()
    temp_var = AverageMeter()
    temp_var_norm = AverageMeter()
    top1 = AverageMeter()
    top5 = AverageMeter()
    mAP = mAPMeter()
    LTtop1 = LTAverageMeter(indices)
    LTtop5 = LTAverageMeter(indices)
    LTmAP = LTMeter(indices)
    model.eval()
    rectified_feats = np.zeros((1, 1004))
    rectified_labels = np.zeros(1)
    all = np.array([90, 148, 262, 639, 753, 46, 79, 91, 107, 116, 17, 33, 119, 129, 152])
    LTconf = LTconfMeter(indices)
    end = time.time()
    with torch.no_grad():
        # vid_id, feature, onehotlabel, index
        for i, (vid, feature, target, index, label) in enumerate(loader):
            label = [np.array(i.split(',')).astype(np.uint32) for i in label]
            feature = feature.cuda()
            target = target.float().cuda()
            temporal_variance = feature.var(1).mean()
            norm_feature = F.normalize(feature, dim=2)
            temporal_normalized_variance = norm_feature.var(1).mean()
            prediction, output = model(feature)

            for r_idx, real in enumerate(label):
                if len(real) > 1:
                    for real2 in real:
                        # if real2 in all:
                        rectified_feats = np.concatenate((rectified_feats, output[r_idx].detach().cpu()), axis=0)
                        rectified_labels = np.append(rectified_labels, real2)
                else:
                    # if real in all:
                    rectified_feats = np.concatenate((rectified_feats, output[r_idx].detach().cpu()), axis=0)
                    rectified_labels = np.append(rectified_labels, real)



            loss = criterion(output, target)

            prec1, prec5 = accuracy(output.data, target, topk=(1, 5))
            corr1, corr5 = perclsaccuracy(output.data, target, topk=(1, 5))
            temp_var.update(temporal_variance.item(), feature.size(0))
            temp_var_norm.update(temporal_normalized_variance.item(), feature.size(0))
            losses.update(loss.item(), feature.size(0))
            top1.update(prec1, feature.size(0))
            top5.update(prec5, feature.size(0))
            LTtop1.update(corr1, label)
            LTtop5.update(corr5, label)
            LTconf.update(prediction, label)
            mAP.add(prediction, target)
            LTmAP.add(prediction, target)

            batch_time.update(time.time() - end)
            end = time.time()

        head_map = LTmAP.value()["head"]
        medium_map = LTmAP.value()["medium"]
        tail_map = LTmAP.value()["tail"]

    output = (
        'Train Results: Accuracy Prec@1,5 {top1.avg:.5f} {top5.avg:.5f} | Loss {loss.avg:.5f} | tempvar {temp_var.avg:.5f} | tempnormvar {temp_norm_var.avg:.5f}'
        .format(top1=top1, top5=top5, loss=losses, temp_var=temp_var, temp_norm_var=temp_var_norm))

    lt_accoutput = (
        'Head@1 {htop1:.5f} H@5 {htop5:.5f} | M@1 {mtop1:.5f} M@5 {mtop5:.5f} | T@1 {ttop1:.5f} T@5 {ttop5:.5f}'
            .format(htop1=LTtop1.value()["head"], htop5=LTtop5.value()["head"], mtop1=LTtop1.value()["medium"],
                    mtop5=LTtop5.value()["medium"], ttop1=LTtop1.value()["tail"], ttop5=LTtop5.value()["tail"]))

    print('\n', lt_accoutput)
    print(output)
    lt_output = ("Overall mAP = {:.3f} {:.5f} {:.5f} {:.5f}". \
                 format(mAP.avg(), head_map, medium_map, tail_map))
    print(lt_output)

    head_conf = LTconf.value()["head"]
    medium_conf = LTconf.value()["medium"]
    tail_conf = LTconf.value()["tail"]
    head_cconf = LTconf.value()["head_c"]
    medium_cconf = LTconf.value()["medium_c"]
    tail_cconf = LTconf.value()["tail_c"]

    lt_confoutput = (
        'Confidence : Head {head_conf:.5f} | Medium {medium_conf:.5f} | Tail {tail_conf:.5f} \n Correct Conf : cHead {head_cconf:.5f} | Medium {medium_cconf:.5f} | Tail {tail_cconf:.5f}'
            .format(head_conf=head_conf, medium_conf=medium_conf, tail_conf=tail_conf,
                    head_cconf=head_cconf, medium_cconf=medium_cconf, tail_cconf=tail_cconf))


    rectified_feats = np.delete(rectified_feats, 0, 0)
    rectified_labels = rectified_labels[1:]

    np.save('./feats/base_allpreds', rectified_feats)
    np.save('./feats/base_allpreds', rectified_labels)

    return top1.avg, top5.avg, mAP.avg()

def rs_train(loader, model, epoch, log):
    batch_time = AverageMeter()
    data_time = AverageMeter()
    losses = AverageMeter()
    top1 = AverageMeter()
    top5 = AverageMeter()
    mAP = mAPMeter()

    model.train() 
    end = time.time()
    
    if args.loss_func == 'LDAM':
        # apply DRW to LDAM
        criterion.reset_epoch(epoch)
    for i, (vid, feature, target, mask) in enumerate(loader):
        feature = feature.cuda()
        target = target.float().cuda(non_blocking=True)
        mask = mask.float().cuda()

        if args.augment == "mixup":
            gamma = np.random.beta(1.0, 1.0)
            mixed_input, mixed_target = Augment.mixup(feature, target, gamma)
            prediction, output = model(mixed_input)
            loss = criterion(output, mixed_target)
        elif args.augment == "None":
            prediction, output = model(feature)
            loss = criterion(output, target)
        else:
            print ("{} not implemented. Please choose ['mixup', 'None'].".\
                    format(args.augment))
            raise NotImplementedError

        loss = loss * mask
        loss = torch.mean(torch.sum(loss, 1))
        losses.update(loss.item(), output.size(0))

        with torch.no_grad():
            prec1, prec5 = accuracy(output.data, target, topk=(1, 5))
            top1.update(prec1, output.size(0))
            top5.update(prec5, output.size(0))
        
        # accumulate gradient for each parameter
        loss.backward()

        if args.clip_gradient is not None:
            total_norm = clip_grad_norm_(model.parameters(), args.clip_gradient)
        
        # update parameters based on current gradients
        optimizer.step()
        optimizer.zero_grad()

        # measure elapsed time
        batch_time.update(time.time() - end)
        end = time.time()

        if i % args.print_freq == 0:
            output = ('Epoch: [{0}][{1}/{2}], lr: {lr:.5f}\t'
                      'Time {batch_time.val:.3f} ({batch_time.avg:.3f})\t'
                      'Loss {loss.val:.4f} ({loss.avg:.4f})\t'
                      'Prec@1 {top1.val:.3f} ({top1.avg:.3f})\t'
                      'Prec@5 {top5.val:.3f} ({top5.avg:.3f})\n'
                      .format(
                epoch, i, len(loader), batch_time=batch_time,
                data_time=data_time, loss=losses, top1=top1, top5=top5, \
                lr=optimizer.param_groups[-1]['lr']))
            sys.stdout.write('\r')
            sys.stdout.write(output)
            sys.stdout.flush()
            # print(output)

            
            log.write(output)
            log.flush()
    
    tf_writer.add_scalar('loss/train_epoch', losses.avg, epoch)
    tf_writer.add_scalar('acc/train_top1', top1.avg, epoch)
    tf_writer.add_scalar('acc/train_top5', top5.avg, epoch)
    tf_writer.add_scalar('lr', optimizer.param_groups[-1]['lr'], epoch)


if __name__=='__main__':
    main()