Source code for domainlab.algos.observers.a_observer

"""
interface for observer + visitor
"""
import abc




class AObVisitor(metaclass=abc.ABCMeta):
    """
    Observer + Visitor pattern for model selection
    """

    def __init__(self):
        self.task = None
        self.device = None
        self.epo_te = None
        self.keep_model = None
        self.loader_te = None
        self.loader_tr = None
        self.loader_val = None



    def set_task(self, task, args, device):
        """
        couple observer with task
        """
        self.task = task
        self.device = device
        self.epo_te = args.epo_te
        self.keep_model = args.keep_model
        self.loader_te = self.task.loader_te
        self.loader_tr = self.task.loader_tr
        # Note loader_tr behaves/inherit different properties than loader_te
        self.loader_val = self.task.loader_val




    @abc.abstractmethod
    def update(self, epoch) -> bool:
        """
        return True/False whether the trainer should stop training
        """




    @abc.abstractmethod
    def accept(self, trainer):
        """
        accept invitation as a visitor
        """




    @abc.abstractmethod
    def after_all(self):
        """
        After training is done
        """




    @abc.abstractmethod
    def clean_up(self):
        """
        to be called by a decorator
        """




    def reset(self):
        """
        reset observer via reset model selector
        """
        self.model_sel.reset()