def train_algorithm(train_cfg, Algorithm, dataset):
    if utils.is_distributed():
        os.environ['OMP_NUM_THREADS'] = train_cfg.experiment.num_workers
    trainer = workers.Trainer()
    output = trainer(train_cfg, Algorithm, dataset=dataset)
    return output
def train_algorithm(train_cfg, Algorithm, dataset):
    if utils.is_distributed():
        os.environ['OMP_NUM_THREADS'] = train_cfg.experiment.num_workers
    trainer = workers.Trainer()
    output = trainer(train_cfg, Algorithm, dataset=dataset)
    return output