<gh_stars>100-1000
# Copyright 2021 Google Inc. All Rights Reserved.
#
# Licensed under the Apache License, Version 2.0 (the "License");
# you may not use this file except in compliance with the License.
# You may obtain a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.

import pytorch_lightning as pl
import torch
import os
from pytorch_pipeline.components.trainer.generic_executor import GenericExecutor


class Executor(GenericExecutor):
    def __init__(self):
        super(GenericExecutor, self).__init__()

    def Do(
        self,
        model_class,
        data_module_class=None,
        data_module_args=None,
        module_file_args=None,
        trainer_args=None,
    ):

        if data_module_class:
            dm = data_module_class(**data_module_args if data_module_args else {})
            dm.prepare_data()
            dm.setup(stage="fit")

            parser = module_file_args
            args = vars(parser.parse_args())
            model = model_class(**args if args else {})

            trainer = pl.Trainer.from_argparse_args(parser, **trainer_args)

            trainer.fit(model, dm)
            trainer.test()

            if "checkpoint_dir" in args:
                model_save_path = args["checkpoint_dir"]
            else:
                model_save_path = "/tmp"

            if "model_name" in args:
                model_name = args["model_name"]
            else:
                model_name = "model_state_dict.pth"

            model_save_path = os.path.join(model_save_path, model_name)
            if trainer.global_rank == 0:
                print("Saving model to {}".format(model_save_path))
                torch.save(model.state_dict(), model_save_path)
