seqskip_test_seq1.py

#!/usr/bin/env python3
# -*- coding: utf-8 -*-
"""
Created on Thu Dec 13 04:24:24 2018

test for seq1 models...

@author: mimbres
"""
import torch
#import numpy as np
import os, time, sys
import argparse
from tqdm import tqdm 
from spotify_data_loader import SpotifyDataloader

parser = argparse.ArgumentParser(description="Sequence Skip Prediction")
parser.add_argument("-c","--config",type = str, default = "./config_init_dataset.json")
parser.add_argument("-m","--model_py", type = str, default="./seqskip_train_seq1HL.py")
parser.add_argument("-s","--save_path",type = str, default="./save/exp_seq1HL/check_1_61011.pth") # directory of saved checkpoint
parser.add_argument("-w","--class_num",type = int, default = 2)
parser.add_argument("-g","--gpu",type=int, default=0)
args = parser.parse_args()

sys.argv = [sys.argv[0]]

GPU = args.gpu
# Module (path of train code including validate() and model) 
MODEL_PATH = args.model_py
# Checkpoint directory
CHECKPOINT_PATH = args.save_path
# Submission output
SUBMISSION_OUTPUT_PATH = os.path.dirname(CHECKPOINT_PATH)

# TSSET stats: 518275860 items within 31251398 sessions
print('Initializing dataloader...')
mtest_loader  = SpotifyDataloader(config_fpath=args.config,
                                  mtrain_mode=False, # False = testset for submission
                                  #data_sel=(0, 100),
                                  batch_size=1792,
                                  shuffle=False,
                                  seq_mode=True) 

#mtest_loader  = SpotifyDataloader(config_fpath=args.config,
#                                  mtrain_mode=True, # True, because we use part of trainset as testset
#                                  data_sel=(99965071, 110075071),#(99965071, 124950714), # 20%를 테스트
#                                  batch_size=10,
#                                  shuffle=True,
#                                  seq_mode=True) 

def save_submission(output, output_path):
    os.makedirs(os.path.dirname(output_path), exist_ok=True)
    with open(output_path,"w") as f:
        for l in tqdm(output, ascii=True):
            line = ''.join(map(str,l))
            f.write(line + '\n')
    tqdm.write('submission saved to {}'.format(output_path))
    return
#%% Main
def main():
    # Import module --> load model
    m = os.path.splitext(os.path.split(MODEL_PATH)[1])[0]
    
    SeqModel         = getattr(__import__(m, fromlist='SeqModel'), 'SeqModel')
    validate        = getattr(__import__(m, fromlist='validate'), 'validate')
    
    SM = SeqModel().cuda(GPU)

    print(CHECKPOINT_PATH)
    print(MODEL_PATH)
    # Load checkpoint
    checkpoint = torch.load(CHECKPOINT_PATH, map_location='cuda:{}'.format(GPU))
    tqdm.write("Loading checkpoint from '{0:}'... epoch:{1:} vacc:{2:.6f}".format(CHECKPOINT_PATH, 
               checkpoint['ep'], checkpoint['hist_vacc'][-1]))
    SM.load_state_dict(checkpoint['SM_state'])

    # Test
    submission = validate(mtest_loader, SM, eval_mode=2, GPU=GPU)
    if len(submission)!=31251398: print("WARNING: submission size not matches.");

    # Save
    fpath = SUBMISSION_OUTPUT_PATH + "/submission_{}.txt".format(time.strftime('%Y%m%d_%Hh%Mm'))
    tqdm.write("Saving...")
    save_submission(submission, fpath)
    tqdm.write("Succesfully saved submission file: {}".format(fpath) )
    return


if __name__ == '__main__':
    main()