Files
2025-06-26 09:17:29 +02:00

56 lines
2.1 KiB
Python

from argparse import ArgumentParser
from core.constants import GPU_IDS, MAX_GPU_MEMORY_ALLOCATION, GLOBAL_CHECKPOINT_DIR
from utils.gpu_limiter import GPULimiter
from utils.preprocess import preprocess
def parse_args():
argument_parser = ArgumentParser()
argument_parser.add_argument("--max-gpu-memory-allocation", type=int, default=MAX_GPU_MEMORY_ALLOCATION)
argument_parser.add_argument("--gpu-ids", type=str, default=GPU_IDS)
argument_parser.add_argument("--study-name", type=str, default="default_study_name")
argument_parser.add_argument("--run-name", type=str, default=None) # randomly chosen by wandb
args = argument_parser.parse_args()
return args
def main():
# 0. Parse arguments.
args = parse_args()
max_gpu_memory_allocation = args.max_gpu_memory_allocation
gpu_ids = args.gpu_ids
print(f"Running on GPU ID {gpu_ids}")
study_name = args.study_name
run_name = args.run_name
checkpoint_dir = f"{GLOBAL_CHECKPOINT_DIR}/{study_name}/{run_name}"
# 1. Set GPU memory limits.
GPULimiter(_gpu_ids=gpu_ids, _max_gpu_memory_allocation=max_gpu_memory_allocation)()
# 2. Data loading/preprocessing
# The preprocess function reads the data and performs preprocessing and encoding for the values of energy,
# angle and geometry
energies_train, cond_e_train, cond_angle_train, cond_geo_train = preprocess()
# 3. Manufacture model handler.
# This import must be local because otherwise it is impossible to call GPULimiter.
from core.model import VAEHandler
vae = VAEHandler(_wandb_project_name=study_name, _wandb_run_name=run_name, _wandb_tags=["single training"], _checkpoint_dir=checkpoint_dir)
# 4. Train model.
histories = vae.train(energies_train,
cond_e_train,
cond_angle_train,
cond_geo_train
)
# Note : One history object can be used to plot the loss evaluation as function of the epochs. Remember that the
# function returns a list of those objects. Each of them represents a different fold of cross validation.
if __name__ == "__main__":
exit(main())